Skip to content

Instantly share code, notes, and snippets.

@ag-ramachandran
Created August 10, 2022 08:16
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ag-ramachandran/4cfa95b2ab24b7561d33671c28f0f92d to your computer and use it in GitHub Desktop.
Save ag-ramachandran/4cfa95b2ab24b7561d33671c28f0f92d to your computer and use it in GitHub Desktop.
OSS Connector config
{
"name": "pbstreams-adx-oss",
"config": {
"connector.class": "com.microsoft.azure.kusto.kafka.connect.sink.KustoSinkConnector",
"flush.size.bytes": 10000,
"flush.interval.ms": 10000,
"tasks.max": 1,
"topics": "pbstreams.sensor",
"kusto.tables.topics.mapping": "[{'topic': 'pbstreams.sensor','db': 'demoDB', 'table': 'PbStreams','format':'json','mapping':'pb_mapping'}]",
"aad.auth.authority": "tenant",
"aad.auth.appid": "app-id",
"aad.auth.appkey": "app-key",
"kusto.ingestion.url": "https://ingest-<cluster>.<region>.kusto.windows.net",
"kusto.query.url": "https://<cluster>.<region>.kusto.windows.net",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter": "com.blueapron.connect.protobuf.ProtobufConverter", <1>
"value.converter.protoClassName": "com.microsoft.kusto.test.protobuf.SensorReadingWithDeviceDataImpl$SensorReading" <2>
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment