apache-kafka Examples and Free Source Code

CompletionException error in KafkaListener while listening KafkaAvro Format events...

azure serialization apache-kafka avro azure-eventhub

DebeziumException "The connector previously stopped while taking a snapshot, but now the connec...

apache-kafka apache-kafka-connect debezium change-data-capture debezium-connect

Need to move small JSON messages from Kafka to HDFS with Kafka Connect but without using Confluent l...

hadoop apache-kafka apache-kafka-connect confluent-platform

How does kafka use write-behind?...

apache-kafka

ModuleNotFoundError: No module named 'kafka.vendor.six.moves' in Dockerized Django Applicati...

python django apache-kafka

Kafka docker image that works without zookeeper...

apache-kafka

Unable to processing messages with spring cloud kafka binder...

java spring apache-kafka spring-cloud-stream

Spring Cloud Stream Kafka Binder - Retries not working when using DLQ in Batch Mode...

spring-boot apache-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

a deployed mircoservice in AKS is not able to connect to deployed kafka in AKS...

kubernetes apache-kafka spring-kafka azure-aks

Kafka Streams List Serdes : is always empty...

java apache-kafka apache-kafka-streams

Java Memory Leak on creating many empty Maps...

java memory apache-kafka cpu spring-kafka

Kafka event driven or polling based...

java apache-kafka

getting "org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 11957...

apache-kafka

Does Kafka-streams commit offset if an exception was thrown during processing?...

apache-kafka apache-kafka-streams

How to decode/deserialize Avro with Python from Kafka...

python apache-kafka avro

Kafka + using prometheus have confilcts with kafka cli commands...

java apache-kafka jmx prometheus ambari

Error creating CDC Azure Database MySQL to Apache Kafka...

azure apache-kafka apache-kafka-connect debezium

Spring-Kafka usage of ConcurrentKafkaListenerContainerFactory for more than One @Kafkalistener...

java spring-boot apache-kafka spring-kafka

Kafka consumers in FastAPI -> different services, different consumer, same producers...

python apache-kafka fastapi aiokafka

org.springframework.kafka.support.serializer.ErrorHandlingDeserializ' of type serializer.ErrorHa...

spring apache-kafka spring-kafka

Caused by: org.messaging.handler.annotation.support.MethodArgumentNotValidException: Could not resol...

spring apache-kafka spring-kafka

Implement Custom Error Handler for Batch Listener in Spring Kafka...

spring spring-boot apache-kafka spring-kafka

Unexpected Kafka request of type METADATA during SASL handshake...

java apache-kafka kafka-producer-api

How can I create topic with kafka-php programming library?...

php apache-kafka

Ad-Hoc Snapshot with Debezium SQL Server Source Connector using Kafka Signal doesn't work...

sql-server apache-kafka snapshot debezium adhoc

org.apache.kafka.common.KafkaException: Failed to construct kafka consumer...

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

Read from configuration kafkalistener...

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

Kafka Connect running out of heap space...

java apache-kafka jvm apache-kafka-connect

Kafka consumer not consuming message after pause and resume...

node.js apache-kafka producer-consumer

KafkaListener got "Caused by: org.springframework.messaging.converter.MessageConversionExceptio...

java apache-kafka spring-kafka avro confluent-schema-registry