Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Spring kafka consumer, seek offset at runtime?

What happens if I don't close the kafka producer

Kafka Stream count on time window not reporting zero values

Structured streaming : watermark vs. exactly-once semantics

Kafka producer send blocks indefinitely when kafka servers are down

Properly Configuring Kafka Connect S3 Sink TimeBasedPartitioner

Guidelines to handle Timeout exception for Kafka Producer?

how many consumer groups can a kafka topic handle?

using mqtt protocol with kafka as a message broker

How can I initialize kafka ConsumerRecords<String,String> in kafka for testing

ClassNotFoundException: org.apache.flink.streaming.api.checkpoint.CheckpointNotifier while consuming a kafka topic

How kafka balances partitions load?

How multiple consumer group consumers work across partition on the same topic in Kafka?

apache-kafka bigdata

What's the best way to design message key in Kafka?

ClassNotFoundException with Kafka consumer

apache-kafka spring-kafka

Kafka Streams: Punctuate vs Process

What is a listener container in Spring for Apache Kafka?

read kafka message starting from a specific offset using high level API

apache-kafka

Kafka Connect implementation errors

java apache-kafka

Kafka startup fails with zookeeper timeout (remote server), yet the machine can connect to zookeeper directly