Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How long would the consumer group alive after the consumers dead?

apache-kafka

Kafka Producer Metrics

kafka server: Offset's topic has not yet been created

go apache-kafka sarama

write to AWS S3 programatically -returns- Roles may not be assumed by root accounts.

Return from Kafka consumer when there is no message

Flink+Kafka reset checkpoint and offset

How Kafka leader replica decides to advance Highwater Mark (HW) when replicating data to follower replicas

Kafka Connector to IBM DB2

mongodb apache-kafka ksqldb

Consuming messages in batch in Kafka using @KafkaListener

Structured Streaming error py4j.protocol.Py4JNetworkError: Answer from Java side is empty

Sarama cannot talk to the Kafka server

go apache-kafka sarama

Failed to connect to and describe Kafka cluster. Check worker's broker connection and security properties

How to run a Kafka Canary Consumer

Spring Kafka ChainedKafkaTransactionManager doesn't synchronize with JPA Spring-data transaction

Is it possible to deserialize Avro message(consuming message from Kafka) without giving Reader schema in ConfluentRegistryAvroDeserializationSchema

Value split is not a member of (String, String)

How to connect to external Oracle database in Docker

Spring Boot Job scheduler with Kafka consumer

Ruby Kafka Uncaught exception: Failed to find group coordinator

How to generate pojo from kafka avro record?