Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

org.apache.kafka.common.KafkaException: Failed to construct kafka consumer

How to find the root cause of high CPU usage of Kafka brokers?

apache-kafka

Use schema to convert AVRO messages with Spark to DataFrame

Kafka Rebalancing and listeners pitfalls

apache-kafka rebalancing

Spring-Kafka Concurrency Property

Spark Streaming + Kafka: SparkException: Couldn't find leader offsets for Set

How to use Android App as a "Producing client" for Kafka?

How to read records in JSON format from Kafka using Structured Streaming?

How to save latest offset that Spark consumed to ZK or Kafka and can read back after restart

Apache Kafka example error: Failed to send message after 3 tries

apache-kafka

Apache Kafka - linger.ms and batch.size settings

KafkaAvroDeserializer does not return SpecificRecord but returns GenericRecord

consumer.How to specify partition to read? [kafka]

How to restart kafka server properly?

kafka + how to avoid running out of disk storage

apache-kafka

Unable to start Zookeeper server - Kafka Setup

Multiple streams from a single master topic

Event sourcing: handle event schema changing

what's the difference between kafka.javaapi.* and org.apache.kafka.*?

api apache-kafka

Is there any simulator/tool to generate messages for streaming?