kafka Authentication with SASL using JAAS
kafka offset 设置
- 如何查看当前offset
- 如何指定offset
使用Kafka时一定要注意防止消费速度过慢触发rebalance而导致的重复消费
配置项
https://spark.apache.org/docs/latest/structured-streaming-kafka-integration.html
问题:
- This means the time between subsequent calls to poll() was longer than the