Wednesday, May 12, 2021

Kafka Summit Europe 2021 - KafkaSummit.io

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"




---

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