Kafka commands

• console related

   # SASL config(producer.properties/consumer.properties)
   sasl.mechanism=SCRAM-SHA-512
   security.protocol=SASL_PLAINTEXT
   sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \
   username="XXXXX" \
   password="XXXXX";
  

  • kafka-console-producer.sh with SASL

     kafka-console-producer.sh --broker-list BROKERS --topic TOPIC --producer.config producer.properties
    

  • kafka-console-consumer.sh with SASL

     kafka-console-consumer.sh --bootstrap-server BROKERS --topic TOPIC --group GROUP_ID --consumer.config consumer.properties