apache-kafka tutorials and guides

Kafka High-level Consumer error_code=15

Jun 17, 2022

apache-kafka kafka-consumer-api

How to deserialize records from Kafka using Structured Streaming in Java?

Dec 23, 2019

java apache-spark apache-kafka spark-structured-streaming

How to ensure constant Avro schema generation and avoid the 'Too many schema objects created for x' exception?

Dec 06, 2019

scala apache-kafka avro confluent-schema-registry reactive-kafka

Kafka as an Akka-persistence journal [closed]

Feb 19, 2022

apache-kafka akka akka-persistence

Kafka SMT ValueToKey - How use multiple values as key?

Dec 24, 2020

oracle jdbc apache-kafka apache-kafka-connect confluent-platform

How to set timeout for onFailure event (Spring, Kafka)?

Sep 07, 2022

java spring spring-mvc apache-kafka spring-kafka

how to change Kafka broker list ip

Nov 14, 2022

apache-kafka

Spring Kafka configure number of partitions for topic

Nov 19, 2022

spring-boot apache-kafka spring-kafka

Reading into SQL Server from Kafka feed [closed]

Dec 17, 2021

sql-server apache-kafka apache-kafka-connect

Kafka Stream aggregation with custom object data type

Oct 26, 2022

apache-kafka aggregation apache-kafka-streams

How to achieve strong consistency in Kafka?

Mar 31, 2022

apache-kafka replication-factor

How to monitor messages rate in Kafka topics?

Oct 24, 2022

apache-kafka monitoring anomaly-detection

Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 1001: org.apache.kafka.common.errors.DisconnectException

Apr 17, 2022

apache-kafka kafka-consumer-api spring-kafka

How to make Spark Streaming (Spark 1.0.0) read the latest data from Kafka (Kafka Broker 0.8.1)

Apr 04, 2022

apache-spark apache-kafka spark-streaming offset kafka-consumer-api

Not able to connect to kafka server on google compute engine from local machine

Oct 27, 2022

google-compute-engine apache-kafka apache-zookeeper

Kafka: No message seen on console consumer after message sent by Java Producer

Aug 17, 2022

java apache-kafka

kafka on kubernetes cannot produce/consume topics (ClosedChannelException, ErrorLoggingCallback)

Oct 29, 2022

docker apache-kafka kubernetes

Sending data with kafka-python only working when briefly delaying code

Mar 19, 2022

python python-2.7 apache-kafka

Why do we need to mention Zookeeper details even though Apache Kafka configuration file already has it?

Aug 22, 2020

apache-kafka apache-zookeeper kafka-consumer-api

Kafka cached zkVersion not equal to that in zookeeper broker not recovering

Sep 15, 2022

apache-kafka apache-zookeeper

New posts in apache-kafka