kafka-consumer-api Examples and Free Source Code

Kafka: Consumer API vs Streams API...

apache-kafka kafka-consumer-api apache-kafka-streams

Understanding Kafka Topics and Partitions...

apache-kafka kafka-consumer-api kafka-producer-api

How to create topics in apache kafka?...

apache-kafka kafka-consumer-api kafka-producer-api

Py4JJavaError: An error occurred while calling t.addCustomDisplayData...

apache-spark pyspark apache-kafka azure-databricks kafka-consumer-api

How to shift back the offset of a topic within a stable Kafka consumer group?...

apache-kafka kafka-consumer-api

How should I properly create a new consumer group and reset the offset from all topics in Kafka CLI?...

java apache-kafka kafka-consumer-api

Why are offsets not reset to 0 after recreating a consumer group with the same group ID?...

apache-kafka kafka-consumer-api

ERROR Unknown error when running consumer: org.apache.kafka.common.errors.SerializationException: Un...

apache-kafka kafka-consumer-api confluent-platform kafka-python

Kafka Manual commit scenario Springboot...

java spring-boot apache-kafka spring-kafka kafka-consumer-api

How Kafka Listener re delivers messages when started consuming messages with auto commit set to fals...

java spring-boot apache-kafka spring-kafka kafka-consumer-api

How can I consume just the last (newest) message from a Kafka topic with Kafka Confluent Consumer?...

c#apache-kafka kafka-consumer-api confluent-kafka-dotnet

How can I read always the newest (last) message from a Kafka Topic that has more then one partition ...

c#apache-kafka kafka-consumer-api confluent-kafka-dotnet

Get kafka consumer protocol version from broker...

apache-kafka kafka-consumer-api

Kafka error handling and deadletter queues...

apache-kafka kafka-consumer-api spring-cloud-stream

How does Kinesis achieve Kafka style Consumer Groups?...

apache-kafka kafka-consumer-api amazon-kinesis

python confluent kafka: Group authorization failed...

python ssl apache-kafka kafka-consumer-api sasl

Inconsistent Results with KStream-KTable Join Under Load...

apache-kafka spring-kafka kafka-consumer-api apache-kafka-streams

module 'snappy' has no attribute 'decompress'...

python python-3.x kafka-consumer-api snappy

How to increase __consumer_offsets replication number on an already running cluster (Kraft kafka 3.4...

apache-kafka kafka-consumer-api replication

KafkIO: unable to create new "old" versions of schema in schema registry, no error...

apache-kafka kafka-consumer-api confluent-schema-registry

Is key required as part of sending messages to Kafka?...

apache-kafka kafka-consumer-api kafka-producer-api

What is the impact if delay kafka manual commit offset?...

java apache-kafka kafka-consumer-api

What is the ideal number of partitions in kafka topic?...

apache-kafka kafka-consumer-api kafka-producer-api kafka-topic

Kafka Listener method could not be invoked with the incoming message...

spring spring-boot apache-kafka kafka-consumer-api

Kafka Msg VS REST Calls...

rest apache-kafka microservices kafka-consumer-api

What is the difference in Kafka between a Consumer Group Coordinator and a Consumer Group Leader?...

apache-kafka kafka-consumer-api

How to fetch messages which are uncommited in kafka...

java apache-kafka kafka-consumer-api

How to flush data to client just after res.write() is written, before res.end(), in Express.js?...

node.js express kafka-consumer-api kafkajs

Monitor the lag for the consumers that are assigned to partitions topic...

apache-kafka kafka-consumer-api

How to pass multiple bootstrap servers for listener using spring-kafka...

apache-kafka kafka-consumer-api spring-kafka