public class KafkaMetadata extends Object implements SpringCloudContractMetadata
Modifier and Type | Class and Description |
---|---|
static class |
KafkaMetadata.ConnectToBroker
Options related to connecting to the real broker.
|
static class |
KafkaMetadata.MessageKafkaMetadata
Kafka message metadata.
|
Modifier and Type | Field and Description |
---|---|
static String |
METADATA_KEY
Key under which this metadata entry can be found in contract's metadata.
|
Constructor and Description |
---|
KafkaMetadata() |
Modifier and Type | Method and Description |
---|---|
String |
description()
Short description of the metadata.
|
static KafkaMetadata |
fromMetadata(Map<String,Object> metadata) |
KafkaMetadata.MessageKafkaMetadata |
getInput() |
KafkaMetadata.MessageKafkaMetadata |
getOutputMessage() |
String |
key()
Name of the key under which this metadata entry will be present in contract's
metadata.
|
void |
setInput(KafkaMetadata.MessageKafkaMetadata input) |
void |
setOutputMessage(KafkaMetadata.MessageKafkaMetadata outputMessage) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
additionalClassesToLookAt
public static final String METADATA_KEY
public KafkaMetadata.MessageKafkaMetadata getInput()
public void setInput(KafkaMetadata.MessageKafkaMetadata input)
public KafkaMetadata.MessageKafkaMetadata getOutputMessage()
public void setOutputMessage(KafkaMetadata.MessageKafkaMetadata outputMessage)
public static KafkaMetadata fromMetadata(Map<String,Object> metadata)
public String key()
SpringCloudContractMetadata
key
in interface SpringCloudContractMetadata
public String description()
SpringCloudContractMetadata
description
in interface SpringCloudContractMetadata
Copyright © 2016–2022 Spring. All rights reserved.