New posts in apache-kafka

Data Modeling with Kafka? Topics and Partitions

apache-kafka apache-zookeeper data-modeling

Debezium Connector tries to open old log file

apache-kafka debezium logminer

Is it possible to force the cleaner to compact a partition log for partitions with very low traffic?

Are Kafka partitions consumed evenly?

Integrating Spark Structured Streaming with the Confluent Schema Registry

apache-spark apache-kafka avro confluent-schema-registry spark-structured-streaming

Leader Not Available Kafka in Console Producer

apache-kafka producer

What determines Kafka consumer offset?

java apache-kafka kafka-consumer-api distributed-computing

Purge Kafka Topic

apache-kafka purge

How to send final kafka-streams aggregation result of a time windowed KTable?

apache-kafka apache-kafka-streams

ConcurrentKafkaListenerContainerFactory message converter is ignored when configuring listeners automatically

spring spring-boot apache-kafka spring-kafka

Using Kafka as a (CQRS) Eventstore. Good idea?

cqrs event-sourcing apache-kafka dddd

Understanding Kafka Topics and Partitions

apache-kafka kafka-consumer-api kafka-producer-api

How do I write a big message into kafka with kafka producer API? [duplicate]

java apache-kafka

Mirror Maker2 not able to connect to target cluster broker

apache-kafka apache-kafka-connect apache-kafka-mirrormaker

Spring cloud stream routing on payload

apache-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

FLINK: Is it possible in the same flink job to read data from kafka topic (file names) and then read files content from amazon s3?

amazon-s3 apache-kafka apache-flink flink-streaming

When to use RabbitMQ over Kafka? [closed]

apache-kafka rabbitmq message-queue

Connect to Kafka on host from Docker (ksqlDB)

docker apache-kafka docker-compose ksqldb

Non-blocking retries with Spring Kafka batch consumer

java spring spring-boot apache-kafka spring-kafka

Connect to Kafka running in Docker

java docker apache-kafka confluent-platform