THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
@PublicEvolving public class KafkaStream implements Serializable { private final String streamId; private final Map<KafkaClusterIdentifier, Set<String>> kafkaClusterTopicMap; public KafkaStream( String streamId, Map<KafkaClusterIdentifier, Set<String>> kafkaClusterTopicMap) { this.streamId = streamId; this.kafkaClusterTopicMap = kafkaClusterTopicMap; } ... } |
...