Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Kafka Streams - kafka-streams-application-reset.sh sending wrong API version

Flink throwing com.esotericsoftware.kryo.KryoException: java.lang.UnsupportedOperationException

Spring kafka setErrorHandler deprecated replacement (boot 2.6.4)

apache-kafka spring-kafka

Ambiguity in the number of partition in server.properties and in topic creation --partition parameter in apache kafka

apache-kafka ambiguity

How to merge multiple kafka streams in order to do a session windowing over all events of the resulting stream

How to expose kafka using istio ingress?

Running Spring Boot application with Kafka in Docker-compose

Kafka listener in test container, avoiding port 9092

How to read from specific Kafka partition in Spark structured streaming

Aug 2019 - Kafka Consumer Lag programmatically

Exactly-once semantics in Flink Kafka Producer

apache-kafka apache-flink

Kafka multiple producer writing to same topic?

apache-kafka

Unable to set CLASSPATH with confluent CLI : java.sql.SQLException: No suitable driver found for jdbc:oracle:thin

Create consumer dynamically spring kafka

EmbeddedKafkaCluster missing?

Spark job fails while filtering kafka messages

Kafka InvalidReceiveException Invalid receive

apache-kafka

Apache Kafka Producer Config Error