Class InternalTopologyBuilder.SubscriptionUpdates
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.SubscriptionUpdates
-
- Enclosing class:
- InternalTopologyBuilder
public static class InternalTopologyBuilder.SubscriptionUpdates extends java.lang.Object
Used to capture subscribed topic via Patterns discovered during the partition assignment process.
-
-
Constructor Summary
Constructors Constructor Description SubscriptionUpdates()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Collection<java.lang.String>
getUpdates()
java.lang.String
toString()
-