drill-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From luoc <l...@apache.org>
Subject Re: How to connect to a Kafka Topic using SASL
Date Fri, 29 Jan 2021 13:28:53 GMT
Hi,
Yes, you can. kafkaConsumerProps is a `java.util.Properties` Object.
Also welcome to join our Slack Channel: https://bit.ly/3t4rozO <https://bit.ly/3t4rozO>

> 2021年1月29日 上午5:36,Jaiswal, Vibhor <vibhor.jaiswal@citi.com.INVALID>
写道:
> 
> Hi ,
> 
> I am trying to connect to the my Kafka Topic which is secured by SASL .Where do I need
to pass the below parameters-
> 
> security:
>        protocol: SASL_PLAINTEXT
>      sasl:
>        mechanism: SCRAM-SHA-256
>        jaas:
>          config: org.apache.kafka.common.security.scram.ScramLoginModule required username="******"
password="*******";
> 
> Can I add them in my storage plugin configuration as below -
> 
> {
>  "type": "kafka",
>  "kafkaConsumerProps": {
>    "key.deserializer": "org.apache.kafka.common.serialization.ByteArrayDeserializer",
>    "auto.offset.reset": "earliest",
>    "bootstrap.servers": "****-phys:9092,****-phys:9092,*****-phys:9092",
>    "enable.auto.commit": "true",
>    "group.id": "drill-query-consumer",
>    "value.deserializer": "org.apache.kafka.common.serialization.ByteArrayDeserializer",
>    "sasl_encrypt": "true",
>    "session.timeout.ms": "30000"
>  },
>  "enabled": true
> }
> Regards,
> Vibhor Jaiswal
> 


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message