Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

get Kafka unconsumed messages count in Java

Kafka topic constantly rolling new log segments, no overrides, logfiles tiny

How to increase the number of executors that process a certain stage in Spark Streaming/Kafka?

No type attribute provided for component property in log4j2 with Spring Boot

Kafka: how to remove broker from Replica Set

apache-kafka

Using a custom converter with Kafka Connect?

Kafka Connect CDC to MS SQL sourceOffset exception

Kafka Stream job not processing / consuming

Randomly generated group id for Kafka Consumer

How to get the offsets programmatically with Kafka 1.0

apache-kafka

Kafka Topic vs. Kafka Log - What is the difference between these two?

apache-kafka kafka-topic

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