mirror of https://github.com/apache/kafka.git
2c0055e62f
Removed readKeyValues() that give UNLIMITED_MESSAGES which will doom to exhaust all wait time, as all its callers actually do provide the expected number of messages. Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Matthias J. Sax <matthias@confluent.io>, Jason Gustafson <jason@confluent.io> Closes #2507 from guozhangwang/KHotfix-not-use-limited-num-messages |
||
|---|---|---|
| .. | ||
| examples/src/main/java/org/apache/kafka/streams/examples | ||
| src | ||