GitHub user amethystic reopened a pull request:
https://github.com/apache/kafka/pull/3148
KAFKA-5327: ConsoleConsumer should manually commit offsets...
KAFKA-5327: ConsoleConsumer should manually commit offsets for those
records it really consumed. Currently it leaves this job to the automatic
offset commit scheme where some unread messages will be passed if
`--max-messages` is set.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/amethystic/kafka
KAFKA-5327_ConsoleConsumer_distable_autocommit
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/3148.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3148
commit fc884eb0bd9940c3914df5e74eae25ff12bb14b9
Author: amethystic
Date: 2017-05-26T03:12:17Z
KAFKA-5327: ConsoleConsumer explicitly set `max.poll.records` if
`--max-messages` is set.
commit 142c6a7cbe5a769d1c582ddc70f0b03269c95b1e
Author: amethystic
Date: 2017-05-26T07:06:37Z
KAFKA-5327: ConsoleConsumer's new consumer commits offsets for those
consumed messages
commit 691cc1dd9080e677f2207c316bd7daef889eb918
Author: amethystic
Date: 2017-05-31T01:04:46Z
merged trunk code
commit 04a72cd9ca847e58cad49873a149ad9e915b7246
Author: amethystic
Date: 2017-05-31T01:59:54Z
Merge branch 'trunk' into KAFKA-5327_ConsoleConsumer_distable_autocommit
commit 13ada359e7bd6028a976e6771ed5042f33c269c1
Author: amethystic
Date: 2017-06-01T10:10:12Z
Cache partitions to which messages are sent in case of creating too many
unnecessary objects to burden the young GC
commit d21b3762b282b8272f059e89875d5f023c3e199d
Author: amethystic
Date: 2017-06-01T10:12:03Z
Merge remote-tracking branch
'origin/KAFKA-5327_ConsoleConsumer_distable_autocommit' into
KAFKA-5327_ConsoleConsumer_distable_autocommit
commit 7f396c842e0ee70c780ad505e81bc77fe894c780
Author: amethystic
Date: 2017-06-01T10:15:19Z
Merge remote-tracking branch 'upstream/trunk' into
KAFKA-5327_ConsoleConsumer_distable_autocommit
commit 4a4ecc8326450a77569f5049093df02a8bd55a4b
Author: amethystic
Date: 2017-06-01T10:25:56Z
KAFKA-5327: ConsoleConsumer should manually commit offsets for those really
consumed messages.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
