Kafka producer config for kafka emitter

Hello,

We are trying to configure kafka-emitter on our druid setup. We have ssl enabled on our kafka cluster so we are providing keystore.password and truststore.password as following,.

“ssl.keystore.password”: {

“type”: “environment”,

“variable”: “KAFKA_KEYSTORE_PASSWORD”

},

“ssl.truststore.password”: {

“type”: “environment”,

“variable”: “KAFKA_TRUSTSTORE_PASSWORD”

}

We are not facing nay issue during ingestion from kafka, but when we try to start druid after providing keystore and truststore in druid.emitter.kafka.producer.config, we get the following error

Cannot deserialize instance of java.lang.String out of START_OBJECT token

at [Source: UNKNOWN; line: -1, column: -1] (through reference chain: org.apache.druid.emitter.kafka.KafkaEmitterConfig[“producer.config”]->java.util.LinkedHashMap[“ssl.keystore.password”]

Has anybody faced this issue before. Can anyone help us out here please?

1 Like