Hello Kafka Users I am a new Kafka user and trying to make Kafka SSL work with Authorization and ACLs. I followed posts from Kafka and Confluent docs exactly to the point but my producer cannot write to kafka broker. I get "LEADER_NOT_FOUND" errors. And even Consumer throws the same errors.
Can someone please share their config which worked with ACLs. Here is my config. Please help. server.properties config ------------------------------------------------------------ ------------------------------------------------ broker.id=0 auto.create.topics.enable=true delete.topic.enable=true listeners=PLAINTEXT://kafka1.example.com:9092 <http://kafka-dev1.example.com:9092/>,SSL://kafka1.example.com:9093 <http://kafka-dev1.example.com:9093/> host.name=kafka1.example.com <http://kafka-dev1.example.com/> ssl.keystore.location=/var/private/kafka1.keystore.jks ssl.keystore.password=12345678 ssl.key.password=12345678 ssl.truststore.location=/var/private/kafka1.truststore.jks ssl.truststore.password=12345678 ssl.client.auth=required ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1 ssl.keystore.type=JKS ssl.truststore.type=JKS authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer ------------------------------------------------------------ ------------------------------------------------ Here is producer Config(producer.properties) ------------------------------------------------------------ ------------------------------------------------ security.protocol=SSL ssl.truststore.location=/var/private/kafka2.truststore.jks ssl.truststore.password=12345678 ssl.keystore.location=/var/private/kafka2.keystore.jks ssl.keystore.password=12345678 ssl.key.password=12345678 ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1 ssl.truststore.type=JKS ssl.keystore.type=JKS ------------------------------------------------------------ ------------------------------------------------ Raqhav
