New post in Apache-kafka

Kafka Storm Integration using Kafka Spout

September 14th, 2022

Delay in Consumer consuming messages in Apache Kafka

September 15th, 2022

Checking the existence of topic in kafka before creating in Java

September 16th, 2022

How to save latest offset that Spark consumed to ZK or Kafka and can read back after restart

September 15th, 2022

Is it possible to create a kafka topic with dynamic partition count?

September 16th, 2022

Logstash with multiple kafka inputs

June 4th, 2022

Is it possible to transfer files using Kafka?

September 14th, 2022

How to have KafkaProducer to use a mock Schema Registry for testing?

June 4th, 2022

How to fix "java.io.NotSerializableException: org.apache.kafka.clients.consumer.ConsumerRecord" in Spark Streaming Kafka Consumer?

June 4th, 2022

Kafka broker constantly ISR shrinking and expanding?

September 15th, 2022

IllegalArgumentException: /tmp/zookeeper/myid file is missing

June 4th, 2022

Failed to resolve 'kafka:9092': Name or service not known - docker / php-rdkafka

June 4th, 2022

Difference between heartbeat.interval.ms and session.timeout.ms in Kafka consumer config

September 15th, 2022

What does commit-log mean in Kafka?

September 14th, 2022

Is it possible to access message headers with Kafka Streams?

June 12th, 2022

Can we disable log4j logs only for kafka

September 14th, 2022

Spark Streaming Exception: java.util.NoSuchElementException: None.get

June 4th, 2022

Apache Kafka - linger.ms and batch.size settings

June 4th, 2022

Unable to connect broker - kafka Tool

September 14th, 2022

kafka + how to avoid running out of disk storage

September 3rd, 2022

How to skip corrupt (non-serializable) messages in Spring Kafka Consumer?

September 16th, 2022

Guidelines to handle Timeout exception for Kafka Producer?

June 4th, 2022

How to find the root cause of high CPU usage of Kafka brokers?

June 4th, 2022

Spring boot Kafka class deserialization - not in the trusted package

September 15th, 2022

Kafka consumer reconnection after getting disconnected

June 4th, 2022

How to fix kafka.common.errors.TimeoutException: Expiring 1 record(s) xxx ms has passed since batch creation plus linger time

June 4th, 2022

How to get message from a kafka topic with a specific offset

September 16th, 2022

Spring-Kafka Consumer KafkaListener cannot convert GenericMessage to Java Object

June 4th, 2022

reading only specific messages from kafka topic

June 4th, 2022

I'm getting "Topic not present in metadata after 60000 ms" message on some computers

June 4th, 2022