Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

@KafkaListener vs ConsumerFactory groupId

Java set Kafka retention time in source code

Unable to start Zookeeper server in Apache Kafka

Can i do some stateful operations in peek or filter or branch of kafka stream apps?

Exposing Kafka cluster in Kubernetes using LoadBalancer service

kubernetes apache-kafka

Is it safe to use Redis pool inside kafka streams?

How to clone field in Kafka Connect?

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?