Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This should be 0.9 to latest with
--new-consumer
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
these two links for your ref:
kafka 0.10.0 tag quickstart_consume
kafka 0.10.1 tag quickstart_consume
i think new consumer api had been used as default api in 0.10.1 without
--new-consumer
. As the links wroten,
--zookeeper
option is default for versions <= 0.10.0, and--bootstrap-server
option is default for versions >= 0.10.1.There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I would consult the source code for ConsoleConsumer rather than the html
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
i find the latest tag of version 0.10.0 (0.10.0.1-rc2) and ealiest tag of version 0.10.1 (0.10.1.0) ,
ver 0.10.0.1-rc2
https://github.com/apache/kafka/blob/a7a17cdec9eaa6c57cc634da6a7c766d98d4160e/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L247
ver 0.10.1.0
https://github.com/apache/kafka/blob/3402a74efb23d1d4fef1e7284de8d4b151cde784/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L290
i think new consumer is the default option for the versions equal to and after 0.10.1.