Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Kafka integration in unity3d throwing Win32Exception error

Kafka transactional producer throws 'Timeout expired while initializing transactional state in 60000ms'

seekToEnd of all partitions and survive automatic rebalancing of Kafka consumers

java apache-kafka kotlin

Kafka Consumer configuration - How does auto.offset.reset controls the message consumption

apache-kafka

How to deal with Kafka warning "Error while loading kafka-streams-version.properties java.lang.NullPointerException: inStream parameter is null"

Kafka Performance Issue

Dynamic Kafka Consumer with AOP

Spark streaming job changing status to ACCEPTED from RUNNING after few days

Cannot access KTable from a different app as StateStore

Kafka SASL_SSL No JAAS configuration section named 'Client' was found in specified JAAS configuration file

kafka consumers registration list in zookeeper

Kafka producer infinite log message: Error while fetching metadata with correlation id 18345 : {input-topic=UNKNOWN_TOPIC_OR_PARTITION}

Local Kafka Application failing with: NoSuchMethodError: createEphemeral

How can I process @KafkaListener method in different threads?

How to get database.server.name for Kafka Debezium MySQL connector?

How to set storm worker's JVM max heap size?

How does librdkafka producer learn about new topic partitions in Kafka

Streaming audio streams trough MQ (scalability)