GitHub user benstopford opened a pull request:
https://github.com/apache/kafka/pull/144
Kafka 2015 - Enable ConsoleConsumer to use new consumer
This extends the original patch done by GZ to provide Console access to
both the new and old consumer API's. The code follows a pattern similar to that
already used in ConsoleProducer.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/benstopford/kafka KAFKA-2015
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/144.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 #144
----
commit 68dc02dcdff89ed20c6b5fab9d24b618ad25c714
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-13T12:36:13Z
KAFKA-2015
commit 6735a6af16d25fa256f8cf91890694316d1e6950
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-13T12:41:43Z
KAFKA-2015
commit 6e23964d608a19509aa9880d8d2944ad795bacd6
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-13T12:42:17Z
KAFKA-2015
commit 68ce8d789a98705e3ee82fbb6c7727db6c8434e2
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-13T17:00:57Z
KAFKA-2015 - implemented base case keeping the existing BaseConsumer design
(which in truth I'm not super-fond of but it retains consistency with
BaseProducer. This checkin still includes TopicPartition, rather than Topic
subscription.
commit dc540f25d0b4708e93c79cbbadf851bc83b8fe5c
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-13T17:29:42Z
KAFKA-2015 - changed to use topic subscription rather than topicpartition
subscription
commit b793f0e9ce0e6496f6fee8322668c2d8149ef573
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-13T18:01:46Z
KAFKA-2015 - tidied leftovers from original Jira Patch from GZ
commit cb5681d27d387a7c428ead3d962bef8acf6b5ff0
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-13T18:15:17Z
KAFKA-2015 - fix indentation
commit 3072e5825e2715ae28cd48fb2bda2b51468d2373
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-14T15:42:39Z
KAFKA-2015 - added some limited testing
commit ba25f099adcc50ef8b5d77c8fe5c1ba137ae02fd
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-14T18:18:14Z
KAFKA-2015 - couple more tests
commit 3d0638f5da2e0d35c74ad6081ac12786103d1d92
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-14T18:20:20Z
KAFKA-2015 - couple more tests
commit 9d01e8ad292039abcc8201de74467b4b4b8af601
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-14T18:41:47Z
KAFKA-2015 - added formatters back in
commit cb0ede65b5c343b6396992a147fc10510e65dbdf
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-14T18:52:09Z
KAFKA-2015 - formatting only
commit 2e9ade93a88641bcdbf1e736dd9d4874a47e854b
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-15T18:03:39Z
KAFKA-2015 - added back in previous change to remove randomly created group
ids from ZK in the shutdown hook
commit de06323b7b75aa4450df16e5315c0db70de06fe0
Author: Ben Stopford <benstopf...@gmail.com>
Date: 2015-08-17T07:53:02Z
KAFKA-2015 - whitespace only
----
---
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.
---
