Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

per message acknowledgement in Kafka / RabbitMQ

Getting only a single record out of many the first time kafka consumer gets a record?

Why does Kafka consumer throw "java.lang.NoClassDefFoundError: kafka/consumer/ConsumerConfig" at startup?

java scala maven apache-kafka

KafkaTemplate send method safe to use without manual (blocking) check of returned future

Can I break anything if I set log.segment.delete.delay.ms to 0

Kafka Streams KTable Store not useful in this case for a compacted input topic, alternatives?

Kafka simple consumer intermittently missing messages

how to get Kafka max offset by producer

apache-kafka

Test kafka and flink integration flow

PySpark direct streaming from Kafka

What is the relationship between connectors and tasks in Kafka Connect?

What is the command to list down all the available brokers in Apache Kafka?

apache-kafka

How Kafka guarantees Consistency and Availability?

Configure SSL and ACLs for kafka-console-consumer

ssl apache-kafka