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
Constraints:
default:
Source kafka bootstrap server ip:port
string
As ^.*$
username
Required
Constraints:
default:
Source cluster username for the bootstrap server
string
As ^.*$
password
Required
Constraints:
default:
Source cluster password for the bootstrap server
string
As ^.*$
application.id
Required
Constraints:
default:
Application id for source e.g. omega-kafka-collector
string
As ^.*$
auto.offset.reset
Required
Constraints:
default:
Source kafka bootstrap server e.g. earliest
string
As ^.*$
group.id
Required
Constraints:
default:
Consumer group id for the bootstrap server
string
As ^.*$
key.deserializer
Required
Constraints:
default:
Consumer property for the source cluster record key deserializer
string
As ^.*$
value.deserializer
Required
Constraints:
default:
Consumer property for the source cluster record value deserializer