Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Consuming from a replica

How to handle error and don't commit when use Kafka Streams DSL

Delayed message consumption in Kafka

kafka binding to ipv6 port even though ipv4 address specified in config

apache-kafka

Storm-Kafka multiple spouts, how to share the load?

Error creating Kafka topic :- replication factor larger than available brokers

How to use multi-thread consumer in kafka 0.9.0?

How do I implement Kafka Consumer in Scala

scala apache-kafka

can't connect to kafka server

java client apache-kafka

Kafka 0.9 How to re-consume message when manually committing offset with a KafkaConsumer

Kafka Producer - org.apache.kafka.common.serialization.StringSerializer could not be found

Acknowledgement.acknowledge() throwing exception in spring-kafka @KafkaListener

Learning Kafka 0.8.2

java apache-kafka

Can I ignore org.apache.kafka.common.errors.NotLeaderForPartitionExceptions?

InstanceAlreadyExistsException coming from kafka consumer

How to monitor JMX metrics of Kafka broker on command line?

apache-kafka jmx

Exception during topic deletion when Kafka is hosted in Docker in Windows

windows docker apache-kafka

Apache Beam over Apache Kafka Stream processing

Kafka SSL handshake failed issue

Can't see timestamps in Apache Kafka 0.10.0.0. RC4

apache-kafka