Michael Heil questions

Michael Heil answers

• Can I break anything if I set log.segment.delete.delay.ms to 0
• ERROR Uncaught throwable from user code: java.lang.IllegalStateException in spark Streaming
• Is it possible in Kafka to read messages in reverse manner?
• How to distribute messages between Kafka topics with different configuration?
• Calculating a moving average column using pyspark structured streaming
• Delete a specific record in a Kafka topic using compaction
• Consuming kafka batch for multiple partitions
• Read Kafka Topic from beginning
• Can Kafka be used as a distribute work queue
• How to use transactions in Kafka and how to use abortTransaction?