Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Asynchronous auto-commit of offsets fails

How to subscribe multiple topic using @KafkaListner annotation

Kafka topic is getting reappeared after 10 sec of deletion

Kafka Consumer Rebalancing and Its Impact

How to reinstate a Kafka Consumer which has been kicked out of the group?

How to write a Spark dataframe into Kinesis Stream?

Error while fetching metadata kafka {test=LEADER_NOT_AVAILABLE}?

Spring Kafka with Dynamic @KafkaListener

KafkaConsumer.commitAsync() behavior with a lower offset than previous

Kafka: consume all messages on demand

How to advance the consumer offset in a Kafka consumer group to the end?

reading only specific messages from kafka topic

Spring Boot and Kafka: Failed to send SSL Close message

Kafka Streams - Multiple Threads or Multiple Instances with same application id

How do you send data from Kafka streams to clients via Websockets in PlayFramework?

What does KafkaConsumer.commitSync() actually commit?

Why does kafka producer have client.id?

Confluent Kafka: Consumer does not read from beginning for all partitions in a topic

Return from Kafka consumer when there is no message