Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

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

How to delete kafka consumer group (created via new consumer api)?

kafka connect hdfs sink connector is failing even when json data contains schema and payload field

Messages lost when Kafka nodes are restarted

apache-kafka

Kafka architecture many partitions or many topics?

Kafka Streams KTable configuration error on Message Hub

Kafka Connect Transformation: Extract a Long value from json field and insert as key

Proper way to programmatically stop an Alpakka Kafka stream