Tag: kafka

• Java 17: implementing Kafka message serialization using Avro and schema registry
• Using Akka Streams with Backpressure in Scala 2.13 - Unexpected Termination of Stream
• Apache Spark 3.4.1 - Reading Data from Kafka with Incorrect Offsets Causes Data Skew
• OCI Stream Processing Delay when Using Python Client Library for Kafka
• Apache Spark 3.4.0 - Unresponsive Behavior When Writing Streaming DataFrames to Kafka with Multiple Partitions
• How to handle the `OutOfMemoryError` in a Spark streaming application using Scala?
• How to set up distributed logging with Log4j2 and Kafka while avoiding message loss?
• Issue with Java 17 and Apache Kafka: Messages Not Being Acknowledged in Consumer with Manual Commit