ableegoldman commented on code in PR #14735:
URL: https://github.com/apache/kafka/pull/14735#discussion_r1412638885
##########
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##########
@@ -580,6 +582,23 @@ public void setGlobalStateRestoreListener(final
StateRestoreListener globalState
}
}
+ /**
+ * Set the listener which is triggered whenever a standby task is updated
+ *
+ * @param standbyListener The listener triggered when a standby task is
updated.
+ * @throws IllegalStateException if this {@code KafkaStreams} instance has
already been started.
+ */
+ public void setStandbyUpdateListener(final StandbyUpdateListener
standbyListener) {
Review Comment:
Agreed!
--
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.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
