Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Kafka Stream Exception: GroupAuthorizationException

Ensuring that all messages have been read from Kafka topic using REST Proxy

What is the correct way to commit after processing each record retrieved from Kafka?

java kotlin apache-kafka

Using Kafka-Go, why am I seeing what appears to be batching reads/writes? Is there a config I am missing?

go apache-kafka

Scaladoc (and Javadoc) for Kafka [closed]

apache-kafka

Kafka Schema Registry error: Failed to write Noop record to kafka store

apache-kafka

Kafka consumer: fetching topic metadata for topics from broker [ArrayBuffer(id:0,host:user-Desktop,port:9092)] failed

Kafka with Docker dynamic advertised_host_name

docker apache-kafka

Is there any way to maintain message ordering between partitions of a kafka topic with a single consumer?

Performing an asynchronous transformation within a Kafka Stream

Read Kafka topic in a Spark batch job

What causes "unknown resolver null" in Spark Kafka Connector?

Kafka Confluent error - java.net.BindException: Address already in use

Apache Kafka 1.0.0 Streams API Multiple Multilevel groupby

Configure Kafka to expose JMX only on 127.0.0.1

Spring Boot / Kafka Json Deserialization - Trusted Packages

Spring Kafka SeekToCurrentErrorHandler Find Out Which Record Has Failed

Kafka Connect | Cannot complete request because of a conflicting operation

Is it ok to use Apache Kafka "infinite retention policy" as a base for an Event sourced system with CQRS?

Lambda Architecture with Apache Spark