Kafka Summit Europe 2021 - KafkaSummit.io
Sources:
"We build and test Apache Kafka with Java 8, 11 and 15.
We set the release parameter in javac and scalac to 8 to ensure the generated binaries are compatible with Java 8
or higher (independently of the Java version used for compilation).
Scala 2.13 is used by default"
https://kafka.apache.org/22/javadoc/index.html?org/apache/kafka/clients/consumer/ConsumerConfig.html
---
kafka 2.2.0 API:
Packages
Package Description
org.apache.kafka.clients.admin
org.apache.kafka.clients.consumer
org.apache.kafka.clients.producer
org.apache.kafka.common
org.apache.kafka.common.acl
org.apache.kafka.common.annotation
org.apache.kafka.common.config
org.apache.kafka.common.config.provider
org.apache.kafka.common.errors
org.apache.kafka.common.header
org.apache.kafka.common.resource
org.apache.kafka.common.security.auth
org.apache.kafka.common.security.oauthbearer
org.apache.kafka.common.security.plain
org.apache.kafka.common.security.scram
org.apache.kafka.common.security.token.delegation
org.apache.kafka.common.serialization
org.apache.kafka.connect.components
org.apache.kafka.connect.connector
org.apache.kafka.connect.data
org.apache.kafka.connect.errors
org.apache.kafka.connect.header
org.apache.kafka.connect.health
org.apache.kafka.connect.rest
org.apache.kafka.connect.sink
org.apache.kafka.connect.source
org.apache.kafka.connect.storage
org.apache.kafka.connect.transforms
org.apache.kafka.connect.util
org.apache.kafka.server.policy
org.apache.kafka.server.quota
org.apache.kafka.streams
org.apache.kafka.streams.errors
org.apache.kafka.streams.kstream
org.apache.kafka.streams.processor
org.apache.kafka.streams.state
org.apache.kafka.streams.test
---
docker pull confluentinc/cp-zookeeper:latest
REM # Confluent Platform packages. There are separate images for each Scala version...
REM # Start Zookeeper and expose port 2181 for use by the host machine
docker run -d --name zookeeper -p 2181:2181 confluentinc/cp-zookeeper
REM # Start Kafka and expose port 9092 for use by the host machine
docker run -d --name kafka -p 9092:9092 --link zookeeper:zookeeper confluentinc/cp-kafka
REM # Start Schema Registry and expose port 8081 for use by the host machine
docker run -d --name schema-registry -p 8081:8081 --link zookeeper:zookeeper --link kafka:kafka confluentinc/cp-schema-registry
REM # Start REST Proxy and expose port 8082 for use by the host machine
docker run -d --name rest-proxy -p 8082:8082 --link zookeeper:zookeeper --link kafka:kafka --link schema-registry:schema-registry confluentinc/cp-kafka-rest
No comments:
Post a Comment