jlprat commented on a change in pull request #10840:
URL: https://github.com/apache/kafka/pull/10840#discussion_r657131881
##########
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##########
@@ -1458,8 +1457,30 @@ public void cleanUp() {
* Note: this is a point in time view and it may change due to partition
reassignment.
*
* @return {@link StreamsMetadata} for each {@code KafkaStreams} instances
of this application
+ * @deprecated since 3.0.0 use {@link KafkaStreams#allRunningMetadata}
*/
- public Collection<StreamsMetadata> allMetadata() {
+ @Deprecated
+ public Collection<org.apache.kafka.streams.state.StreamsMetadata>
allMetadata() {
+ validateIsRunningOrRebalancing();
+ return
streamsMetadataState.getAllMetadata().stream().map(streamsMetadata ->
+ new
org.apache.kafka.streams.state.StreamsMetadata(streamsMetadata.hostInfo(),
+ streamsMetadata.stateStoreNames(),
+ streamsMetadata.topicPartitions(),
+ streamsMetadata.standbyStateStoreNames(),
+ streamsMetadata.standbyTopicPartitions()))
+ .collect(Collectors.toSet());
+ }
+
+ /**
+ * Find all currently running {@code KafkaStreams} instances (potentially
remotely) that use the same
+ * {@link StreamsConfig#APPLICATION_ID_CONFIG application ID} as this
instance (i.e., all instances that belong to
+ * the same Kafka Streams application) and return {@link StreamsMetadata}
for each discovered instance.
+ * <p>
+ * Note: this is a point in time view and it may change due to partition
reassignment.
+ *
+ * @return {@link StreamsMetadata} for each {@code KafkaStreams} instances
of this application
+ */
+ public Collection<StreamsMetadata> allRunningMetadata() {
Review comment:
I decided to for for the pattern xxxForxxx to keep consistency among
different changes.
It is now `metadataForAllStreamsClients` but happy to change if anyone has
reasons against it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
