Connector config

config.json

{
    "name": "pbstreams-adx", <1>
    "config": {
        "connector.class": "com.microsoft.azure.kusto.kafka.connect.sink.KustoSinkConnector",
        "key.converter.schema.registry.url": "http://schema-registry:8081", <2>
        "value.converter.schema.registry.url": "http://schema-registry:8081",
        "flush.size.bytes": 10000, <3>
        "flush.interval.ms": 10000,
        "tasks.max": 1,
        "topics": "pbstreams.sensor", <4>
        "kusto.tables.topics.mapping": "[{'topic': 'pbstreams.sensor','db': 'demoDB', 'table': 'PbStreams','format':'json','mapping':'pb_mapping'}]",
        "aad.auth.authority": "tenant", <5>
        "aad.auth.appid": "app-id", 
        "aad.auth.appkey": "app-key",
        "kusto.ingestion.url": "https://ingest-<cluster>.<region>.kusto.windows.net",<6>
        "kusto.query.url": "https://<cluster>.<region>.kusto.windows.net",
        "key.converter": "org.apache.kafka.connect.storage.StringConverter",
        "value.converter": "io.confluent.connect.protobuf.ProtobufConverter"<7>
    }
}