Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to dynamically add consumers in consumer group kafka

How to process logs from distributed log broker (Eg Kafka) exactly after 1 week?

How to get kafka message's headers in Kafka Connect Sink connector with MongoDB

How to implement request-reply (synchronous) messaging paradigm in Kafka?

Spark Structured Streaming program that reads from non-empty Kafka topic (starting from earliest) triggers batches locally, but not on EMR cluster

Using Apache Kafka for log aggregation

storm nimbus not starting: Getting below error

kafka: what do 'soTimeout', 'bufferSize' and 'minBytes' mean for SimpleConsumer?

Apache Spark-Kafka.TaskCompletionListenerException & KafkaRDD$KafkaRDDIterator.close NPE on local cluster(Client Mode)

Rereading message from Kafka topic by refusing acknowledgement

After Linux restart, Kafka throwing "no brokers found when trying to rebalance"

Delayed Queue implementation in Storm – Kafka, Cassandra, Redis or Beanstalk?

Kafka TOPIC_AUTHORIZATION_FAILED

apache-kafka acl jaas

Kafka sink connector: No tasks assigned, even after restart

Kafka : Deserialization issues during poll

Spring Boot Kafka Startup error "Connection to node -1 could not be established. Broker may not be available."

Kafka Streams 2.5.0 requires input topic

Apache Kafka error on windows - Couldnot find or load main class QuorumPeerMain

Got user-level KeeperException when processing

Apache kafka: Failed to acquire lock on file .lock in tmp/kafka-logs

apache-kafka