Kafka Streams 4.x Java 11 Compatibility...

Handle multiple responses with ReplyingKafkaTemplate...

Debezium with kafka or only embedded-Debezium?...

Produce integer (INT32) keys with Kafka Connect...

Debezium New Record State Extraction SMT doesn't work properly in case of DELETE...

Kafka Share Consumer not consume messages...

With Spring Boot, a kafkaTemplate.send(topic, msg).join() returns a producer record and its metadata...

Unable to write Iceberg record in S3...

Is it possible to replicate kafka topics without alias prefix with MirrorMaker2...

Kafka: Consumer API vs Streams API...

I have packages librdkafka librdkafka-dev on my Debian 13, but CMake find_package don't find the...

Google PubSub to Kafka Source connector...

Spring Kafka: UnknownHostException: 34bcfcc207e0...

Understanding Kafka Topics and Partitions...

How to create topics in apache kafka?...

Py4JJavaError: An error occurred while calling t.addCustomDisplayData...

How to connect Elasticsearch deployed by Elastic Operator correctly in a Kafka connector?...

what is the difference between client.id and group.instance.id...

Simple embedded Kafka test example with spring boot...

How to shift back the offset of a topic within a stable Kafka consumer group?...

Testing custom Kafka Connect SMT using Test Containers...

Kafka load test on Gatling...

Spring Kafka Consume JsonNode objects...

How to make fanout in Apache Kafka?...

Is it possible to filter records before materializing a GlobalKTable?...

Testcontainers SchemaRegistry can't connect to Kafka container...

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

How to write a jsonArray to Kafka topic in node js...

Why does kafka wants data to be binary (array of bytess) in topics?...

How do I normalize the JSON response in the filebeat configuration...