Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Using Custom Kafka State Stores in kstreams application

Error: Could not locate bindings file node-librdkafka.node

How to load history data when starting Spark Streaming process, and calculate running aggregations

Kafka Streams - all instances local store pointing to the same topic

Spark Streaming application fails with KafkaException: String exceeds the maximum size or with IllegalArgumentException

Activiti with kafka backbone

java apache-kafka activiti

Failed to start bean kafkaListenerContainer: java.lang.IllegalArgumentException

Kafka consumer error Cancelled in-flight API_VERSIONS request with correlation id 1 due to node -1 being disconnected

What is the "offset was changed from X to 0" error with a KafkaSource in Spark Structured Streaming?

Kafka Connector - Packacking jars

Kafka enable.auto.commit values for each consumer

Kafka Connect Confluent S3 Sink Connector: Class io.confluent.connect.avro.AvroConverter could not be found

Connecting Eclipse Ditto to Apache Kafka

Kafka Keyless Producer In Java