Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How does kafka decides the partition if I don't mention any

Kafka Error in I/O java.io.EOFException: null

apache-kafka

External system queries during Kafka Stream processing

Is kafka consumer 0.9 backward compatible?

Kafka multiple partition ordering

Kafka console consumer get partition

Kafka server SSL configuration exception

apache-kafka

How to choose the no of partitions for a kafka topic?

Kafka-connect, Bootstrap broker disconnected

KAFKA - ERROR Failed to write meta.properties due to (kafka.server.BrokerMetadataCheckpoint)

apache-kafka

Error while creating topic in kafka

apache-kafka

kafka-python consumer start reading from offset (automatically)

What is reason for getting ProducerFencedException during producer.send?

kafka-python raise UnrecognizedBrokerVersion Error

How to slow down or set given speed on the Kafka stream consumer?

what is bootstrap-server in kafka config?

apache-kafka

Apache Kafka - KafkaStream on topic/partition

How to use Project Reactor's Scheduler with Executor based libraries?

org.apache.kafka.common.errors.TimeoutException: Topic not present in metadata after 60000 ms

How to convert JavaPairInputDStream into DataSet/DataFrame in Spark