Я использую KafkaIO в потоке данных для чтения сообщений из одной темы. Я использую следующий код. KafkaIO.<String, String>read() .withReadCommitted() .withBootstrapServers(endPoint)...