NiFi消耗卡夫卡sasl_plaintext问题

如何解决NiFi消耗卡夫卡sasl_plaintext问题

我正在尝试在nifi中使用sasl_plaintext安全性从主题配置Oracle云流kafka。虽然下面提到了即时获取问题和堆栈跟踪；也请看看外观和jass配置。希望有人帮助我解决这个问题；而且我也在bootstrap.conf文件中进行了配置；

我也尝试过nifi处理器本身；这是配置img；

kafka版本2.0和kafka nifi kakfaconsumer_processor也也消费了kafka_record_2.0处理器。 NiFi-1.9,2

java.arg.16=-Djava.security.auth.login.config=/home/opc/nifi-1.9.2/kafka_client_jaas.conf

kafka_client_jaas.conf

KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="aaabbb"
password="cccdddde";
};




2020-10-30 05:41:18,638 WARN [Timer-Driven Process Thread-6] org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-2,groupId=devtes_grp] Connection to node -1 terminated during authentication. This may indicate that authentication Failed due to invalid credentials.
2020-10-30 05:41:18,691 WARN [Timer-Driven Process Thread-6] org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-2,719 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@b4bca55 // Another save pending = false
2020-10-30 05:41:18,794 WARN [Timer-Driven Process Thread-6] org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-2,groupId=devtes_grp] Connection to node -1 terminated during authentication. This may indicate that authentication Failed due to invalid credentials.
2020-10-30 05:41:19,047 WARN [Timer-Driven Process Thread-6] org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-2,450 WARN [Timer-Driven Process Thread-6] org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-2,groupId=devtes_grp] Connection to node -1 terminated during authentication. This may indicate that authentication Failed due to invalid credentials.
2020-10-30 05:41:20,255 WARN [Timer-Driven Process Thread-6] org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-2,groupId=devtes_grp] Connection to node -1 terminated during authentication. This may indicate that authentication Failed due to invalid credentials.
2020-10-30 05:41:21,114 WARN [Timer-Driven Process Thread-6] org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-2,920 WARN [Timer-Driven Process Thread-6] org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-2,groupId=devtes_grp] Connection to node -1 terminated during authentication. This may indicate that authentication Failed due to invalid credentials.
2020-10-30 05:41:22,875 WARN [Timer-Driven Process Thread-6] org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-2,groupId=devtes_grp] Connection to node -1 terminated during authentication. This may indicate that authentication Failed due to invalid credentials.
2020-10-30 05:41:23,189 INFO [NiFi Web Server-19] o.a.n.c.s.StandardProcessScheduler Stopping ConsumeKafkaRecord_2_0[id=7479eb76-0175-1000-bee8-c2013de52f23]

解决方法

我可以解决此问题。我添加了具有默认java caerts，密码和jks类型的standardslsecurityservice，并更改了安全协议-SASL，安全机制-普通