Member since
07-19-2017
14
Posts
1
Kudos Received
0
Solutions
02-15-2019
06:41 AM
@Krishna Pandey are you able to connect HBASE thrift2 ?
... View more
10-31-2018
08:30 AM
@Paul Hernandez Are you using nifi in cluster mode? If yes, you can try change consume MQTT to primary node instead of all nodes. Hope it helps!
... View more
10-26-2018
02:06 AM
@Adrian Oprea Thanks for your answer. I fixed the issue already. My post above was using the same naming of xx.jks file in the share drive and not suppose in this way. I just placed each of the host's jks on local drive (node1.jks, node2.jks, node3.jks) and set 'StandardRestrictedSSLContextService' with one of them. So I used node1.jks. Worry about other nodes not recognize? No worried, nifi site to site will handle this and it worked fine for me.
... View more
07-03-2018
12:10 PM
@Matt Clarke do you have any suggestion? Thanks in advance
... View more
07-03-2018
12:08 PM
Problem: I have 3 NiFi nodes (non ambari manage cluster) and each of the nodes have their own certificate. I would like to build this flow rest-api-flow on my secured NiFi Cluster. So I referred to this article and updated the same password & name on each of the nodes. Originally I have... node1.jks, password=node1 node2.jks, password=node2 node3.jks, password=node3 Then renamed each of them as shared_keystore.jks with the same password 'changeit' based on this article. So now I have the same name of shared_keystore.jks with password=changeit where generated with the following command: On node1: keytool -storepasswd -new changeit -keystore node1.jks keytool -keypasswd -alias [Alias name forprivate key]-keystore node1.jks cp node1.jks shared_keystore.jks On node2: keytool -storepasswd -new changeit -keystore node2.jks keytool -keypasswd -alias [Alias name forprivate key]-keystore node2.jks cp node1.jks shared_keystore.jks On node3: keytool -storepasswd -new changeit -keystore node3.jks keytool -keypasswd -alias [Alias name forprivate key]-keystore node3.jks cp node1.jks shared_keystore.jks Then I set SSLContextService as sslcontextservice.jpg but I still got the error as sslcontextservice2.jpg May I know any better suggestion on this?
... View more
Labels:
- Labels:
-
Apache NiFi
11-24-2017
01:36 AM
@Rajesh Reddy
Is your Kafka broker security protocol using PLAINTEXT? But when you consume/produce you used SASL_PLAINTEXT (client.properties/consumer.properties) ? Maybe you can try disable kerberos security and try whether Kafka working or not in none-security mode then only enable to security for further testing. Since you do not have ranger policy, I think the account that you're using should be okay. But prefer use the same account for troubleshooting
... View more
11-23-2017
09:40 AM
@wsalazar I already have the KepServer and I need to add OPCUA as additional NiFi processor to get the data from that server. I downloaded your git (https://github.com/wadesalazar/NIFI-OPCUA) and run 'mvn package' then copy 'opc-ua-stack-1.03.342.1-SNAPSHOT.jar' to Nifi's lib but seem like not working. Any step I missed or went wrong?
... View more
11-23-2017
09:35 AM
Yes, if you keberized your cluster
... View more
11-22-2017
11:32 PM
@Rajesh Reddy What is your kafka log telling? Maybe you can try something like this... Consumer: /bin/kafka-console-consumer.sh
--zookeeper zk1:2181,zk2:2181,zk2:2181 --topic
your_topic_name --security-protocol SASL_PLAINTEXT --from-beginning Producer: /bin/kafka-console-producer.sh
--broker-list
broker1:6667,broker2:6667 --topic your_topic_name--security-protocol SASL_PLAINTEXT If issue due to security (make sure backup your original file in case not working): KafkaClient { com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true keyTab="/etc/security/keytabs/kafka.service.keytab" storeKey=true useTicketCache=false serviceName="kafka" principal="kafka/<hostname>@<domain.com>"; }; Client {
com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true keyTab="/etc/security/keytabs/kafka.service.keytab" storeKey=true useTicketCache=false serviceName="zookeeper" principal="kafka/<hostname>@<domain.com>";; };
... View more
11-22-2017
04:50 PM
@Jay Kumar SenSharma Thanks for replied. I’m
using Apache Maven 3.2.1 & Java version: 1.8.0_101. I had changed pom.xml's system path version from opc-ua-stack-1.03.340.0-SNAPSHOT.jar to opc-ua-stack-1.03.342.1-SNAPSHOT.jar due to the OPCFoundation stack verison is /UA-Java/target/opc-ua-stack-1.03.342.1-SNAPSHOT.jar. Seeing ed3766 posted (URL) But I think the changes had updated to the git repo and I had try copy & pasted the codes to StandardOPCUAService.java and same error occur. Either I have to modify the codes or get the owner's answer about this issue but is there any alternative way to add opcua into NiFi as per mentioned here URL ? Thanks for your support 🙂
... View more