Michael Heil questions

Michael Heil answers

• Kafka Producer guarantees
• Asynchronous auto-commit of offsets fails
• How to write streaming DataFrame into multiple sinks in Spark Structured Streaming
• How to use widgets to pass dynamic column names in Dataframe select statement
• Read latest message from kafka - segmentio/kafka-go
• When is it appropriate to use a UDF vs using spark functionality? [closed]
• KafkaConsumer.commitAsync() behavior with a lower offset than previous
• How to advance the consumer offset in a Kafka consumer group to the end?
• Is the leader part of ISR list
• Use single streaming DataFrame for multiple output streams in PySpark Structured Streaming