PHP rdkafka. How to consume topic matching regular expression?...

How do I access the fields within a VARIANT column while reading from Kafka using Spark?...

Kafka error handling and deadletter queues...

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

Avro AVSC to C# classes...

How can I prevent the "Telemetry client instance id changed from AAAAAAAAAAAAAAAAAAAAAA to&quot...

How does Kinesis achieve Kafka style Consumer Groups?...

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

kafka offset in spark...

Need Kafka KRAFT SASL_PLAINTEXT...

Is there any api or tool for getting ingestion ratio in a kafka topic...

python confluent kafka: Group authorization failed...

Custom transform for Kafka Connect...

Kafka commit after making sure all messages are actually processed...

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

kafka async message producer: retry does not work...

Question about connector plugin versions in Strimzi's Kafka Connect...

Kafka Streams KTable-KTable foreign key join emits null even if right side is empty...

Kafka does not start blank output...

Data Loss in Flink Job with Iceberg Sink After Restart: How to Ensure Consistent Writes?...

Is there a limit on consumers and consumer groups?...

Pause MSK Kafka Connector (Sink) without deleting...

setting the value serializer only works via the constructor with 3 params, the map configuration is ...

Kafka 3.3 with Kraft - Controller ID keeps changing every second...

Kafka auto assigns new topics/partitions to dead/fenced brokers...

publishEndpoint.Publish() Not Sending Messages with Kafka in MassTransit...

Inconsistent Results with KStream-KTable Join Under Load...

Is it possible to create kafka topics without additional service in docker-compose?...

Apache Flink and State Store from Kafka Data Source...

Kafka topic creation uses wrong configuration...