public class TopicRecordIdStrategy extends RecordIdStrategy
Constructor and Description |
---|
TopicRecordIdStrategy() |
Modifier and Type | Method and Description |
---|---|
String |
artifactId(String topic,
boolean isKey,
org.apache.avro.Schema 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, org.apache.avro.Schema schema)
ArtifactIdStrategy
artifactId
in interface ArtifactIdStrategy<org.apache.avro.Schema>
artifactId
in class RecordIdStrategy
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.