ConfigureSourcePropertiesObject

ConfigureSourcePropertiesObject
ConfigureSourcePropertiesObject

kafka Consumer properties for the source cluster

JSON Example
{
    "bootstrap.servers": "localhost:9092",
    "username": "string",
    "password": "string",
    "application.id": "omega-kafka-collector",
    "auto.offset.reset": "earliest",
    "group.id": "omega-consumer-group",
    "key.deserializer": "org.apache.kafka.common.serialization.StringDeserializer",
    "value.deserializer": "org.apache.kafka.common.serialization.StringDeserializer"
}
string As ^.*$
bootstrap.servers
Required

Source kafka bootstrap server ip:port

string As ^.*$
username
Required

Source cluster username for the bootstrap server

string As ^.*$
password
Required

Source cluster password for the bootstrap server

string As ^.*$
application.id
Required

Application id for source e.g. omega-kafka-collector

string As ^.*$
auto.offset.reset
Required

Source kafka bootstrap server e.g. earliest

string As ^.*$
group.id
Required

Consumer group id for the bootstrap server

string As ^.*$
key.deserializer
Required

Consumer property for the source cluster record key deserializer

string As ^.*$
value.deserializer
Required

Consumer property for the source cluster record value deserializer