[GitHub] kafka pull request #3362: MINOR: StreamThread standbyTask comment typo

GitHub user zqhxuyuan opened a pull request: https://github.com/apache/kafka/pull/3362 MINOR: StreamThread standbyTask comment typo log info typos. should be standby task, not active task. You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] kafka pull request: valueFactory's key is consumerId

GitHub user zqhxuyuan opened a pull request: https://github.com/apache/kafka/pull/817 valueFactory's key is consumerId the key of partitionAssignment's valueFactory is consumerId, not topic. partitionAssignment.getAndMaybePut(threadId.consumer) You can merge this pu