Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How can be handle oracle decimal types with GoldenGate "Kafka" / "Kafka connect" handler?

Spark Streamming : Reading data from kafka that has multiple schema

Using SSL with Kafka on a single node

security ssl apache-kafka

Stream delete events from MySQL to PostgreSQL via Apache-kafka

Kafka Streams Application Updates

Completely uninstall confluent on linux

Kafka - org.apache.kafka.common.errors.NetworkException

Spark Structured Streaming with Kafka - How to repartition the data and distribute the processing among worker nodes

Kafka Stream Chained LeftJoin - Processing previous old message again after the new one

Kafka not receiving messages when indicating group_id in Python

How does Consumer.endOffsets work in Kafka?

Cannot connect to Kafka from Flask in a dockerized environement

What are the practical limits of Kafka regex-topics / listening to multiple topics

How to dynamically add consumers in consumer group kafka

How to process logs from distributed log broker (Eg Kafka) exactly after 1 week?

How to get kafka message's headers in Kafka Connect Sink connector with MongoDB

How to implement request-reply (synchronous) messaging paradigm in Kafka?

Spark Structured Streaming program that reads from non-empty Kafka topic (starting from earliest) triggers batches locally, but not on EMR cluster

Using Apache Kafka for log aggregation

Kafka Streams 2.5.0 requires input topic