Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Getting ProducerFencedException on producing record in Kafka listener thread

How to define Scala API for Kafka Streams as dependency in build.sbt?

kafka topic creation faling when 3 brokers are up out of 4 in a cluster

KSQL Join more than two streams

Apache Kafka: seek and assignment. Reliable read from beginning

IllegalStateException: please consider configuring an 'ErrorHandlingDeserializer' in the value and/or key deserializer

How to approach configuration as code for Kafka topics in AWS MSK?

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