Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

flink: handling backpressure (source: kafka, sink: elasticsearch)

Using Kafka java producer send a message: Producer connection to localhost:9092 unsuccessful

java apache-kafka

PySpark Structured Streaming: trigger once not working with Kafka

Check message has been written to kafka topic using command line

apache-kafka

Kafka throttle producer based on consumer lag

How to configure kafka consumer with sasl mechanism PLAIN and with security protocol SASL_SSL in java?

listTopics with kafka-clients-2.6.0 gives TimeoutException

java apache-kafka

AWS MSK lambda concurrent consumers

Iterate Through Spark DataFrame in Java without Collect

Spring Kafka filtering messages by header on a listener level

Kafka Best Practices + how to set recommended setting for JVM

java jvm apache-kafka

Connection to node -1 (/127.0.0.1:9092) could not be established. Broker may not be available

apache-kafka spring-kafka

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