Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Kafka message codec - compress and decompress

compression apache-kafka

Kafka-python get number of partitions for topic

Kafka multiple consumers for a partition

Kafka consumer - what's the relation of consumer processes and threads with topic partitions

I can't run zookeeper

org.apache.kafka.common.config.ConfigException: Missing required configuration "bootstrap.servers" which has no default value

max.poll.intervals.ms set to int.Max by default

Consuming from single kafka partition by multiple consumers

Kafka - Docker - Error when sending message from Host to Container (Batch Expired)

docker apache-kafka

Spring Boot Kafka: Unable to start consumer due to NoSuchBeanDefinitionException

How to reset offsets to arbitrary value in Kafka Consumer Group?

apache-kafka

Does Kafka support secure communication?

apache-kafka

Kafka Consumer hanging at .hasNext in java

How to get kafka consume lag in java program

java apache-kafka

Error when Spark 2.2.0 standalone mode write Dataframe to local single-node Kafka

RecordTooLargeException in Kafka streams join

How to manage Kafka KStream to Kstream windowed join?

Kafka only once consumption guarantee

apache-kafka

Kafka - Broker: Group coordinator not available

TimeoutException: Timeout expired while fetching topic metadata Kafka