Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

how to get acknowledgement from Kafka broker if message is produced by producer?

Kafka 0.9 - How to create a topic through java api [closed]

java apache-kafka

Kafka CommitFailedException consumer exception

Purpose and difference b/w Apache camel Kafka consumer URI option consumerStreams vs consumersCount

apache-camel apache-kafka

Docker (Compose) client connects to Kafka too early

Kafka streams.allMetadata() method returns empty list

Kafka Consumer: How to start consuming from the last message in Python

How to automate Kafka Testing

Error in Publishing message to Kafka topic

Kafka: How do I enable client logging?

Logstash with Kafka: Unable to decode avro

KafkaStreams - InconsistentGroupProtocolException

How to determine a Kafka consumer's offset

apache-kafka spring-kafka

Can we disable log4j logs only for kafka

How can I access my AWS MSK managed kafka queue from my local machine and EC2 instances in other regions

Kafka producer is connecting to localhost instead of the real IP

Kafka with Zookeeper 3.5.7 Crash NoSuchMethodError: java.nio.ByteBuffer.flip()

What is the difference between simple consumer and high level consumer?

apache-kafka

Apache Flink streaming in cluster does not split jobs with workers

INFO Closed socket connection for client /127.0.0.1:48452 which had sessionid 0x15698f5ac360001 (org.apache.zookeeper.server.NIOServerCnxn)