Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in 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

Interact with kafka docker container from outside of docker host [duplicate]

Query Kafka topic for specific record

apache-kafka

Kafka schema registry not compatible in the same topic

Difference between KTable and local store

Kafka "Login module not specified in JAAS config"

java apache-kafka jaas sasl