[{"label":"Latest (2.0.1)","version":"latest"}]
telco-cloud-service-assurance
DefaultSourcePropertiesObject
kafka Consumer properties for the source cluster
Properties
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 ^.*$
bootstrap.servers
Required
Source kafka bootstrap server ip:port
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
JSON Example
{
"application.id": "omega-kafka-collector",
"auto.offset.reset": "earliest",
"bootstrap.servers": "localhost:9092",
"group.id": "omega-consumer-group",
"key.deserializer": "org.apache.kafka.common.serialization.StringDeserializer",
"value.deserializer": "org.apache.kafka.common.serialization.StringDeserializer"
}
[{"label":"Latest (2.0.1)","version":"latest"}]
telco-cloud-service-assurance
Property Of
DefaultBlockSourceObject
