Использовать транзакции PublishKafka_2_0

#apache-kafka #apache-nifi #apache-kafka #apache-nifi Вопрос: Я использую следующую конфигурацию процессора публикации Kafka: Отредактированная конфигурация kafka и zookeeper: zookeeper.properties authProvider.sasl=org.apache.zookeeper.server.auth.SASLAuthenticationProvider requireClientAuthScheme=sasl jaasLoginRenew=3600000 zookeeper_jaas.conf Server { org.apache.zookeeper.server.auth.DigestLoginModule required user_super="zookeeper" user_admin="admin-secret"; }; server.properties…