public class TopicIdStrategy<T> extends Object implements ArtifactIdStrategy<T>
Constructor and Description |
---|
TopicIdStrategy() |
Modifier and Type | Method and Description |
---|---|
String |
artifactId(String topic,
boolean isKey,
T schema)
For a given topic and message, returns the artifact id under which the
schema should be registered in the registry.
|
public String artifactId(String topic, boolean isKey, T schema)
ArtifactIdStrategy
artifactId
in interface ArtifactIdStrategy<T>
topic
- the Kafka topic name to which the message is being published.isKey
- true when encoding a message key, false for a message value.schema
- the schema of the message being serialized/deserializedCopyright © 2019 Red Hat. All rights reserved.