Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Bean instantiation via factory method failed; exception org.springframework.beans.BeanInstantiationException

Kafka Consumer Group: read new messages only

node.js apache-kafka

Is there a way to update configuration of a running kafka connector

Read a CSV file in real time using Kafka Connect

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