| Interface | Description |
|---|---|
| InternalDeserializer<P> |
Internal Deserializer
Used by SDK to deserialize an object of P type,
|
| InternalSerializer<P> |
A Internal Message Serializer Interface,
Used by SDK to serialize an object ot type P
|
| MessageStructure |
A common interface for the message structure.
|
| Class | Description |
|---|---|
| AvroMessageDeserializer |
Avro Message Deserializer
It used internally by
Consumer.poll(long) }
after reading a ConsumerRecord |
| AvroMessageSerializer |
Avro Message Serializer
It used internally by
#send(com.opendxl.streaming.nativeclient.producer.ProducerRecord,
com.opendxl.streaming.nativeclient.producer.Callback) )} }
before sending a ProducerRecord |
| AvroV1MessageSchema |
Avro Schema Registry
Avro Schema V1
{
"namespace": "com.intel.databus.client",
"type": "record",
"name": "DatabusMessage",
"fields": [{
"name": "headers",
"type": {
"type": "map"
"values": "string"
}
}, {
"name": "payload"
"type": "bytes"
}]
}
|
| DatabusKeyDeserializer |
Deserializer for Databus key
|
| DatabusKeySerializer |
Serializer for Databus key
|
| DeserializerRegistry |
Contains a key-value Collection of message version and Deserializer.
|
| LegacyMessageDeserializer |
Deserilize Legacy JSON messages
|
| LegacyMessageStructure |
Represent a Legacy Message Structura based on JSON
|
| MessageDeserializer |
Deserialize a message based on
MessageStructure getInstance |
| MessageSerializer |
Serializer message based on
MessageStructure getInstance |
| MessageStructureConstant |
Contains a set of constants for Message Structure
|
| MessageStructureFactory |
Factory for MessageStructure getInstance
|
| RawMessageDeserializer |
Deserialize messages produced by Kafka Client.
|
| RawMessageStructure |
Represents a message produced with a non-SDK producer, for getInstance Kafka SDK.
|
| RegularMessageStructure |
Represents a
DatabusMessage structure. |