THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
@PublicEvolving
public class KafkaClusterIdentifier implements Comparable<KafkaClusterIdentifier>, Serializable {
private final String name;
private final String bootstrapServers;
...
} |
KafkaStream
It is possible that a Kafka stream is composed of multiple topics on multiple Kafka clusters. In addition, this flexible and general abstraction does not require any conventions on the topic naming but implementations can make assumptions to do so if desired. In the simplest case, a Kafka stream is a single topic on a single Kafka cluster.
| 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;
}
...
} |
...