THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Status
Current state: Under DiscussionVote
Discussion thread: here
JIRA: here
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
| Code Block | ||
|---|---|---|
| ||
/**
* Returns information about the local stream threads running in a {@link KafkaStreams} application.
*
* @return the set of {@link ThreadMetadata}.
*/
public Set<ThreadMetadata> localThreadsMetadata() {
validateIsRunning();
Set<ThreadMetadata> threadMetadata = new HashSet<>();
for (int i = 0; i < threads.length; i++)
threadMetadata.add(threads[i].threadMetadata());
return threadMetadata;
} |
In addition, the current toString() method should be deprecated as it would result to return inconsistent information with the new API.
A straightforward first pass is GitHub PR 2612
...