Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Does commitOffsets on high-level consumer block?

Kubernetes - Can't connect to a service IP from the service's pod

apache-kafka kubernetes

How to read records from Kafka topic from beginning in Spark Streaming?

Kafka Streams: Proper way to exit on error

Apache Pulsar vs. Apache RocketMQ [closed]

Kafka -> Flink DataStream -> MongoDB

Can we update/Upsert a record in mongodb? data source is kafka

How to manually set group.id and commit kafka offsets in spark structured streaming?

How to set group.id for consumer group in kafka data source in Structured Streaming?

KAFKA and SSL : java.lang.OutOfMemoryError: Java heap space when using kafka-topics command on KAFKA SSL cluster

Send KafkaProducer from local machine to hortonworks sandbox on virtualbox

Apache Kafka order windowed messages based on their value

Kafka leader election causes Kafka Streams crash

How to check Kafka server status or details?

apache-kafka

Kafka Java API offset operations clarification

Kafka Offset after retention period

Implementing sagas with Kafka

Does kafka have any default web UI [closed]

Kafka vs StreamSets

KafkaSpout working example [closed]