How connect Lagom to external Kafka server using TLS?

[Dustin Shimono]

Hi,

How would Lagom be configured for consumers/producers to connect to an external Kafka server using TLS?

A CLI consumer example using TLS would set these properties:  

kafka-console-consumer –bootstrap-server kafka.tls.com:9093 –topic foo –new-consumer –from-beginning –consumer.config /etc/kafka/consumer_ssl.properties

consumer_ssl.properties

bootstrap.servers=kafka.tls.com:9093

group.id=securing-kafka-group

security.protocol=SSL

ssl.truststore.location=/etc/security/tls/kafka.client.truststore.jks

ssl.truststore.password=test1234

ssl.keystore.location=/etc/security/tls/kafka.client.keystore.jks

ssl.keystore.password=test1234

ssl.key.password=test1234

Where would I put these properties so Lagom would configure the Kafka consumer/producer to use TLS?

Thanks,

Dustin

[Tim Moore]

Hi Dustin,

You can configure the Kafka client in your service's application.conf file by placing properties inside a section labelled "akka.kafka.consumer.kafka-clients" for consumer config or "akka.kafka.producer.kafka-clients" for producer config.

See the docs for details: http://www.lagomframework.com/documentation/1.2.x/java/KafkaClient.html#apache-java-kafka-client

Cheers,

Tim

--
You received this message because you are subscribed to the Google Groups "Lagom Framework Users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to lagom-framework+unsubscribe@googlegroups.com.
To post to this group, send email to lagom-framework@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/lagom-framework/8db091d5-d2b9-4444-81bb-9a9a02d33832%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

--

Tim Moore

Senior Engineer, Lagom, Lightbend, Inc.

tim....@lightbend.com
+61 420 981 589
Skype: timothy.m.moore