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
...