Cómo configurar la autenticación del cliente con Beam KafkaIO

He estado revisando los tutoriales de Beam KafkaIO y he estado tratando de encontrar documentación sobre la autenticación del cliente kafka, pero hasta ahora solo he encontrado ejemplos muy básicos. Necesito proporcionar la siguiente configuración para que el cliente Kafkaio se autentique correctamente:

bootstrap.servers=kafka1:9093
security.protocol=SSL
ssl.truststore.location=/var/private/ssl/kafka.client.truststore.jks
ssl.truststore.password=test1234
ssl.keystore.location=/var/private/ssl/kafka.client.keystore.jks
ssl.keystore.password=test1234
ssl.key.password=test1234

¿Cómo especificaría esta configuración?

Hasta ahora, todo lo que he encontrado en los ejemplos es configurar de esta manera:

p.apply(KafkaIO.<Long, String>read()
.withBootstrapServers("kafka1:9022")
.withTopic("test-topic")
.withKeyDeserializer(LongDeserializer.class)
.withValueDeserializer(StringDeserializer.class)
Respuesta 1

He hecho una pequeña aplicación de red C ++. Produce los intercambios de paquetes en un archivo. La salida se ve así: De ... a ... mensaje 1 2 "hola" 2 3 "hola" 3 2 "hola atrás" 2 1 "hola atrás" Entonces, el primer campo ...

Como usuario Cuando voy a una página Luego hay un elemento que se desplaza hacia abajo a la vista Hay un enlace en el que quiero hacer clic en ese elemento. A veces funcionará, pero ¿cómo espero que termine de desplazarse ...

Estoy usando sockets TCP / IP en Java para intentar crear una aplicación cliente-servidor. El programa funciona bien cuando se ejecuta localmente y también a través de la red de área local, pero cuando uso la dirección IP de Internet ...

Obtuve el código a continuación de un código de muestra desde el punto de tutoriales y lo ajusté un poco. App.java public static void main (String [] args) lanza ParseException {CommandTest t = new ...