The following changes are required in each broker server:
- To enable SSL for communications between brokers, make the following changes in the broker properties:
security.inter.broker.protocol = SSL
- To configure communication protocols and set SSL ports, make the following changes in server properties:
listeners=SSL://host.name1:port,SSL://host.name2:port
If you have not set SSL for inter-broker communication, you will need to set listeners properties such as this: listeners=PLAINTEXT://host.name:port,SSL://host.name:port
- To give SSL keystore and truststores path for each broker, you should make the following changes in the server properties of each broker:
ssl.keystore.location = /path/to/kafka.broker.server.keystore.jks ...