Я работаю над конвейером потоковой передачи данных apache с производителем Kafka в качестве входа и потребителем для выхода. Может ли кто-нибудь помочь мне с КПП в apache -балке