Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in kafka-consumer-api

Node Kafka - Duplicate messages are coming

KafkaException: Wrong request type 18

How Do I know whether my record has been Manually committed using Spring Kafka

Get the time the message reached Kafka

Error while staring spring boot Kafka project

Kafka incremental sticky rebalancing

Python-Kafka: Keep polling topic infinitely

Get Latest Message for a Confluent Kafka Topic in Python

How to define multiple serializers in kafka?

Circuit breaker with kafka consumer

retrieve messages in a topic using kafka-python

Running kafka connect in Distributed mode?

Kafka consumer not consuming from beginning

import error no module named kafka

Getting the last message sent to a kafka topic

Kafka Consumer Group Id and consumer rebalance issue

strange behavior of kafka tool : kafka.tools.GetOffsetShell

Is there a way to manually store Kafka offset so a consumer never misses messages?

Can we listen to specific keyed messages by Kafka Consumer