Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

What is the best practice to retry messages from Dead letter Queue for Kafka

What if a Kafka's consumer handles a message too long? Will Kafka reappoint this partition to another consumer and the message will doubly handled?

How does Apache Kafka use open file descriptors?

apache-kafka

Retrieving Kafka broker properties from a client

apache-kafka

Are Kafka Streams Appropriate for Triggering Batch Processing of Records?

How to set TOPOLOGY_MAX_SPOUT_PENDING parameter

Spring Boot + Kafka + Kerberos configuration

org.apache.kafka.common.KafkaException: io.confluent.kafka.serializers.KafkaAvroSerializer

Kafka topic and multiple instances of a microservice

How to tune/edit/add/change the kafka docker container parameters outside from the container

docker apache-kafka

Is it possible to consume kafka messages using key and partition?

Read data from Kafka and print to console with Spark Structured Sreaming in Python

Kafka compression: How to do compression at single message level

Kafka min.insync.replicas < replication.factor

java apache-kafka

Describe Kafka Consumer Groups Response

Why doesn't a KSQL stream not return/show data from messages on topic in broker?

apache-kafka ksqldb

Kafka off-heap memory leak

Can i add topics to my @kafkalistener at runtime

How to run a Kafka connect worker in YARN?