Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

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)

Pausing a kafka topic with multiple consumers

ld: library not found for -lrt

How does kafka decides the partition if I don't mention any

Kafka Error in I/O java.io.EOFException: null

apache-kafka

External system queries during Kafka Stream processing

Is kafka consumer 0.9 backward compatible?