Thanks for reporting this! Would you like to open a MINOR PR to fix it? Don't think we need a Jira for this.
-Matthias On 6/16/17 9:26 AM, john cheng wrote: > https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java#L1345 > > This Line: > log.info("{} Adding assigned standby tasks {}", logPrefix, partitionAssignor > .activeTasks()); > The parameter is active task, but the info content is standby tasks. > > This should be change to > > log.info("{} Adding assigned standby tasks {}", logPrefix, partitionAssignor > .standbyTasks()); >
signature.asc
Description: OpenPGP digital signature
