Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Difference between session.timeout.ms and max.poll.interval.ms for Kafka

Commit offset in Reactor Kafka

AWS Elastic Beanstalk unable to access AWS MSK

How consumer groups works in kafka?

How to send 1 Kafka message with a key?

ReadFromKafka stuck in beam process with Dataflow

Caveats of scaling a Kafka cluster vertically vs horizontally?

apache-kafka

Read from Kafka topic process the data and write back to Kafka topic using scala and spark

Topic consumption rate

Apache Samza local storage - OrientDB / Neo4J graph instead of KV store

spark-submit classpath issue with --repositories --packages options

Batch consumer camel kafka

Flink + Kafka + JSON - java example

Apache Kafka Avro Deserialization: Unable to deserialize or decode Specific type message.