Welcome at microwebservices.eu, my interests: microservices.com.pl, Java, cloud on AWS, J2EE, containerization/Dockerization, Kubernetes, JEE, EJB, JSP, Maven, Web Services, SOAP, REST, High Availability Systems, Genetic Algorithms, Neural Networks etc. See linkedin.com/in/grathor33/, bitbucket.org and https://github.com/grathor33/
Monday, May 31, 2021
Saturday, May 29, 2021
Thursday, May 27, 2021
Tuesday, May 25, 2021
Monday, May 24, 2021
Tuesday, May 18, 2021
Sunday, May 16, 2021
Saturday, May 15, 2021
Friday, May 14, 2021
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"
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
Sunday, May 9, 2021
Subscribe to:
Posts (Atom)