Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Avro decoding gives java.io.EOFException

Setting Partition Strategy in a Kafka Connector

Is it a good way to run Kafka on Kubernetes?

Kafka as a message queue for long running tasks

how to use Kafka 0.8 Log4j appender

log4j appender apache-kafka

Kafka Streams - updating aggregations on KTable

Kafka Maven Dependencies

Connecting Kafka-Python with a cluster with Kerberos

python apache-kafka

Kubernetes how to access a service from another namespace

apache-kafka kubernetes

Kafka Connect Out of Java heap space after enabling SSL

Kafka: The message when serialized is larger than the maximum request size you have configured with the max.request.size configuration

Failing to write offset data to zookeeper in kafka-storm

Why isn't kafka continuing to work on fail of one of the brokers?

apache-kafka

Kafka python consumer reading all the messages when started

What is the different between kafka artifactIds kafka_2.10 and kafka-clients?

apache-kafka

How to stop a flink streaming job from program

Kafka Streams processors - state store and input topic partitioning

Configure kafka-net to stop sending latest messages

kafka consumer group is rebalancing

Reading Avro messages from Kafka with Spark 2.0.2 (structured streaming)