"streamType": "kafka",

"stream.kafka.topic.name": "asdas",

"stream.kafka.consumer.type": "lowlevel",

"stream.kafka.broker.list": "asasds.westeurope.azure.confluent.cloud:9092",

"stream.kafka.consumer.factory.class.name": "org.apache.pinot.plugin.stream.kafka20.KafkaConsumerFactory",

"security.protocol": "SASL_SSL",

"sasl.mechanism": "PLAIN",

"sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"\" password=\"\";",

"ssl.endpoint.identification.algorithm": "https",

"auto.offset.reset": "earliest",

"<http://stream.kafka.consumer.prop.request.timeout.ms|stream.kafka.consumer.prop.request.timeout.ms>": "60000",

"<http://stream.kafka.consumer.prop.metadata.max.age.ms|stream.kafka.consumer.prop.metadata.max.age.ms>": "60000",

"stream.kafka.decoder.class.name": "org.apache.pinot.plugin.inputformat.avro.confluent.KafkaConfluentSchemaRegistryAvroMessageDecoder",

"stream.kafka.decoder.prop.schema.registry.rest.url": "<https://dasdsa.westeurope.azure.confluent.cloud>",

"stream.kafka.decoder.prop.schema.registry.basic.auth.credentials.source": "USER_INFO",

"<http://stream.kafka.decoder.prop.schema.registry.basic.auth.user.info|stream.kafka.decoder.prop.schema.registry.basic.auth.user.info>": ":",

"stream.kafka.decoder.prop.schema.registry.schema.name": "KsqlDataSourceSchema",

"stream.kafka.decoder.prop.format": "AVRO"