DefaultSourcePropertiesObject

DefaultSourcePropertiesObject

kafka Consumer properties for the source cluster

JSON Example

{
    "bootstrap.servers": "localhost:9092",
    "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 ^.*$

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

Property Of

DefaultBlockSourceObject