Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Understanding kafka streams partition assignor

Purpose of statestore and changelog topic in kafka streams?

Does Kafka's message include timestamp by default?

apache-kafka

What is the difference between Kafka partitions and Kafka replicas?

Zookeeper-Kafka and Consistent hashing

Kafka repartitioning

running Kafka on WSL and make producer on windows

java windows apache-kafka

pyspark structured streaming kafka - py4j.protocol.Py4JJavaError: An error occurred while calling o41.save

Kafka as a data store for future events

Failed to connect to seed broker with kafkajs

Data still remains in Kafka topic even after retention time/size

apache-kafka

Failed to connect to Confluent Platform Schema Registry - Apache Flink SQL Confluent Avro Format

Flink (on docker) to consume data from Kafka (on docker)

How to optimize aggregation so that aggregatiton per consumer is done first?

Sharing Kafka producer between threads