Releases: leancloud/kafka-java-consumer
Releases · leancloud/kafka-java-consumer
Release 0.1.2
- Fix a bug which may pause partition forever #21
- a little improvement on partition reassignment #20
Release 0.1.1
- fixed a bug on partial commit #16
- some minor refact #17
Release 0.1.0
- Fixed a bug on async commit policy, which may caused a lot duplicate commit request to kafka broker. #13
- Support retry for sync commit when cached a
RetriableException
#14
Release 0.0.8
- Support force seek offsets to beginning or end #12
- Fix trigger wakeup on consumer voluntarily exit #11
- Remove some redundant logs
Release 0.0.6
- support subscribe to pattern #7
- support returns a future when subscribed to some topic which will be complete when the consumer shutdown or some error occur. #8
- support set handle record timeout #9
Release 0.0.5
- recommit those that have committed offsets to broker periodically for all non-automatic commit consumers. #5
Release 0.0.4
- Fix a NPE on doing a recommit: d4c088b
Release 0.0.3
- more integration tests #3
- recommit periodically #2
- support metrics from Kafka consumer
- let worker pool as a option configuration
- graceful shutdown