Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Conditional logic on a Reactor Flux

Kafka Connect failing to read from Kafka topics over SSL

Kafka - How to skip a bad message in an offset and consume the rest

java apache-kafka

Kafka compare consecutive values for a key

Flink Tumble Window Trigger time

Kafka topic no longer exists after restart

How to create multiple kafka consumer groups in same topic

apache-kafka consumer

Why does kafka producer have client.id?

Re-assignment of Partition gets infinitely stuck in "Still in progress" state

Write a csv file to a kafka topic

Kafka repartitioning ( for group by based on key)

Confluent Kafka: Consumer does not read from beginning for all partitions in a topic

How to handle bad messages in spark structured streaming

C# Unable to consume message on Kafka topic?

Kafka Partition and Throughput

apache-kafka

Not able to send large messages to Kafka

Does a Kafka Streams app commit offets for a topic used to fill a Global KTable?

Kafka Sink: ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectStandalone:130)

Kafka connect cannot find broker in docker

How to modify kafka connector?