Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Kafka to Google Cloud Platform Dataflow ingestion

Kafka: java client failed to send messages after x tries

java apache-kafka

Topic( s) [xxx] is/are not present and missingTopicsFatal is true

Apache Kafka consume events from different topics in specific order

Tuning S3 file sizes for Kafka

Access Kafka in Remote Host by IP Address running with Docker-Compose and Spring Boot

Spring Boot Kafka Consumer throwing No bean named 'kafkaListenerContainerFactory' available

Spring-Kafka usage of ConcurrentKafkaListenerContainerFactory for more than One @Kafkalistener

What does KafkaConsumer.commitSync() actually commit?

Recommended settings for Kafka Internal Topics after upgrade to 1.0

apache-kafka

Kafka Consumer in Node.js

kafka mirrormaker 2 custom partitioner

Understanding of kafka auto-offset-reset

apache-kafka

Serde class for AVRO primitive type

When does Zookeeper change Kafka cluster ID?

Is there a way to start/stop Kafka consumer in a Spring app manually?

How to get Kafka header's value to Spark Dataset as a single column?

Kafka: What do the numbers in controller_epoch and leader_epoch mean?

apache-kafka

How do we map multiple collections to multiple topics in the mongodb-sink-connector?

How to produce a json object message into kafka topic using java(spring)?