Feature Request: SSL configuration

[vineethvijay7]

First of all, really appreciate the work you have done here. Works pretty well for a non ssl kafka setup :))

But for a production grade setup which includes ssl auth and encryption, it would be be great to make use of this.

Have you thought about this before? If you could also suggest in some ways I could may be make changes to this ? (PS: I'm no java expert)

May the java client could make use of Kafka standard environment variables?

such as KAFKA_SSL_* ?

[vineethvijay7]

@chengkuangan

[chengkuangan]

@vineethvijay7 You can change the KafkaPerformance constructor to include the settings for TLS. Refer the details for the Kafka Client TLS settings here

You can then mount the TLS cert during runtime or you can do it during container build time in Dockerfile