Kafka的Simple Consumer并不简单。相反的,它是直接在对Kafka的partition和offset进行操作,是一种比较接近底层的方案。
为什么要使用Simple Consumer
使用SimpleConsumer最主要的原因是想在消费消息时获取更大的权限。比如说要做下面这些事情:
- 多次读取同一条消息;
- 在一个处理过程中,只消费topic中partiti
Kafka的Simple Consumer并不简单。相反的,它是直接在对Kafka的partition和offset进行操作,是一种比较接近底层的方案。
使用SimpleConsumer最主要的原因是想在消费消息时获取更大的权限。比如说要做下面这些事情: