Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to set offset committed by the consumer group using Spark's Direct Stream for Kafka?

Broker replication error "Not authorized to access topics: [Topic authorization failed.] "

apache-kafka

How to reconnect kafka producer once closed?

Is it possible to disable caching for some kafka topics?

apache-kafka

What is the reasoning behind Kafka Connect Schemas?

Advantages of dockerizing Java Springboot application?

kafka network Processor error in producer program(ArrayIndexOutOfBoundsException: 18)

what is key schema in schema registry?

How to properly restart a kafka s3 sink connect?

validation for kafka topic messages

apache-kafka

Pushing avro file to Kafka

apache-kafka avro

Having trouble with Ubuntu .profile and .bashrc

Put data first in Kafka or Database?

database apache-kafka

Deserializing different JSON payload from same Kafka topic with Spring Kafka

Why kafka streams state dir is in /tmp/kafka-streams?

Spring Kafka Idempotence Producer configuration

apache-kafka spring-kafka

How to make consume method as non blocking in confluent kafka for dot net

Should we use max.poll.records or max.poll.interval.ms to handle records that take longer to process in kafka consumer?

Getting java.nio.file.AccessDeniedException on kafka on Windows

Kafka instead of Rest for communication between microservices