apache-kafka Examples and Free Source Code

Spring Cloud Stream Multi Cluster and Multi Input Bindings from a Single Consumer...

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

Kafka DefaultErrorHandler Seek to current after exception...

java apache-kafka spring-kafka

How docker map env variable to kafka broker variable?...

docker apache-kafka docker-compose

Issues with RabbitMQ Source Connector Configuration - java.io.IOException Errors with SSL...

apache-kafka rabbitmq apache-kafka-connect

Can't migrate old data from zookeeper cluster to KRaft cluster via MirrorMaker2...

apache-kafka apache-kafka-mirrormaker

Kafka consumer is missing messages during deployment...

python django apache-kafka apache-zookeeper kafka-python

Handling bad messages using Kafka's Streams API...

error-handling apache-kafka apache-kafka-streams

How can I access Confluent Cloud Schema Registry using KafkIO?...

apache-kafka confluent-schema-registry confluent-cloud

Running Kafka on Windows 10 fails: The system cannot find the path specified...

windows apache-kafka

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

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

Why do we need Outbox pattern with Kafka...

apache-kafka microservices event-driven idempotent

Get the latest offsets in SSL Enabled Kafka via CMD...

apache-kafka

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

Spring Kafka, overriding max.poll.interval.ms?...

java apache-kafka spring-kafka

KafkaAvroSerializer for serializing Avro without schema.registry.url...

java apache-kafka avro confluent-schema-registry

Transactional outbox distributed lock fencing confusion...

apache-kafka microservices messaging outbox-pattern transactional-outbox

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

sql-server apache-kafka snapshot debezium adhoc

Need to run kafka-storage.sh on every broker and controller...

apache-kafka apache-zookeeper kraft

Consumer gives "This server does not host this topic-partition" error...

node.js apache-kafka kafkajs

Kafka producer callback Exception...

apache-kafka kafka-producer-api

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

python django apache-kafka

problems with Schema Registry associated with Azure Event Hub from KafkaConnect using Strimzi...

apache-kafka apache-kafka-connect avro confluent-schema-registry strimzi

Kafka Streams state store vs MongoDB for state management...

mongodb apache-kafka architecture apache-kafka-streams

Handling entity merges in Kafka when the events for both entities are across two separate partitions...

apache-kafka

Setting Schema Registry Proxy URL and Port...

apache-kafka proxy confluent-schema-registry

Apache Kafka metadata fetch takes more than 40 sec to read and fetch why?...

apache-kafka

Kafka Consumers leave some messages unread...

.net apache-kafka confluent-kafka-dotnet

kafka mysql source connect errorKafka Connect JDBC Source Connector Fails to Start: IllegalAccessErr...

mysql apache-kafka jdbc apache-kafka-connect

org.apache.kafka.common.errors.TimeoutException: Topic not present in metadata after 60000 ms...

java windows apache-kafka kafka-producer-api