New posts in apache-kafka

Java Lang Null Pointer Error connecting DB2 iOS with Debezium and Kakfa Connect for CDC pull

How to decode/deserialize Avro with Python from Kafka

confluent platform vs apache kafka [closed]

How to stop Spring Kafka Listner and invoke some function to execute after the Consumer is stopped?

What do the state and coordinator columns in AKHQ mean?

Spring Boot Embedded Kafka can't connect

Webhook data to Kafka Connect

Kafka Msg VS REST Calls

Sink connector looking for topic -value schema instead of record name

What are the advantages and disadvantages of Kafka over Apache Pulsar [closed]

Kafka + Zookeeper: Connection to node -1 could not be established. Broker may not be available

What are Apache Kafka topic name limitations?

How to read data using Kafka Consumer API from beginning?

Successor to deprecated FlinkKafkaProducer

Why is Kafka pull-based instead of push-based?

The input line is too long when starting kafka

Increase the number of messages read by a Kafka consumer in a single poll

How does an offset expire for an Apache Kafka consumer group?

How to expose a headless service for a StatefulSet externally in Kubernetes

When does the Apache Kafka client throw a "Batch Expired" exception?