Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

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

Is it possible to create multiple spouts in one topology? how?

apache-storm apache-kafka

Kafka suddenly reset the consumer Offset

How to use Flink's KafkaSource in Scala?

kafka-log4j-appender 0.9 does not work

java.lang.NoClassDefFoundError: kafka/common/TopicAndPartition

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?

kafka cant connect to zookeeper- FATAL Fatal error during KafkaServerStable startup

Kafka Monitoring JMX Attributes Count or MeanRate?

jmx apache-kafka jmxtrans

Kafka set the maximum number of messages to read from the topic

How to pick a Kafka transaction.id

java apache-kafka

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'