Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

spring kafka listener is looking ContainerProperties at wrong place

Apache storm using Kafka Spout gives error: IllegalStateException

How come kafka fails to commit offset for a particular partition?

apache-kafka

Kafka Streams: What are the negative consequences of having a slow punctuate job?

How to store only latest key values in a kafka topic

Kafka time difference last two records, KSQL or other?

Kafka: client has run out of available brokers

go apache-kafka sarama

KTable/KStream memory consumption over time

How to set optimal config values - trigger time, maxOffsetsPerTrigger - for Spark Structured Streaming while reading messages from Kafka?

structured streaming Kafka 2.1->Zeppelin 0.8->Spark 2.4: spark does not use jar

Does Kafka supports XA transactions?

Kafka connect Debezium Postgres Cloud SQL

The coordinator is not aware of this member even with very large poll interval

java apache-kafka

How can i kill distributed worker in Kafka cluster?

Is there anything special about Kafka's message keys?

apache-kafka

Connecting Kafka producer/consumer to broker via TLS

PyKafka metadata in bytes instead of strings

python apache-kafka pykafka

How can you use TLS for Kafka in Quarkus?

Why is kafka not creating a topic? bootstrap-server is not a recognized option

Classpath is empty. Please build the project first e.g. by running './gradlew jar -PscalaVersion=2.11.12'