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