Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Replicating messages from one Kafka topic to another kafka topic

apache-kafka

AbstractMethodError creating Kafka stream

kafka-server-stop.sh not working when Kafka started from Python script

python linux apache-kafka

UnknownHostException kafka

Kafka create topic with default number of partitions

apache-kafka

Kafka consumer offsets out of range with no configured reset policy for partitions

Kafka-consumer. commitSync vs commitAsync

JMS vs Kafka in specific conditions

jms apache-kafka

Why do .index files exist in the kafka-log directory?

apache-kafka

How to produce messages to selected partition using kafka-console-producer?

apache-kafka

Limit Kafka batches size when using Spark Streaming

Make Kafka Topic Log Retention Permanent

Kafka Consumer: No entry found for connection

Why do Kafka consumers output INVALID_FETCH_SESSION_EPOCH after updating to 1.1?

Spark Kafka Direct DStream - How many executors and RDD partitions in yarn-cluster mode if num-executors is set?

Creating a realtime push notification system for desktop/mobile/web apps using kafka as message broker

Kafka setup with docker-compose

Kafka: Continuously getting FETCH_SESSION_ID_NOT_FOUND

apache-kafka

Receiving Kafka event on web browser real time

javascript apache-kafka

Kafka on Kubernetes multi-node