Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Kafka increasing processing timeout message

My Kafka consumer retry for 10 times abnormally, and stop its retrying by simply adding a MDC log?

How to consume from Kafka topic in multiple goroutines, using Sarama?

How to send Kafka message from one topic to another topic?

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?