文章目录
- Spark Streaming 整合 Kafka
-
- 一、版本说明
- 二、项目依赖
- 三、整合Kafka
-
- 3.1 ConsumerRecord
- 3.2 生产者属性
-
- 1. fetch.min.byte
- 2. fetch.max.wait.ms
- 3. max.partition.fetch.bytes
- 4. session.timeout.ms
- 5. auto.offset.reset
- 6. enable.auto.commit
- 7. client.id
- 8. max.poll.records
- 9. receive.buffer.bytes 和 send.buffer.byte