About yimsiokek

yimsiokek · ‎02-15-2019

@Krishna Pandey are you able to connect HBASE thrift2 ?

yimsiokek · ‎10-31-2018

@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!

yimsiokek · ‎10-26-2018

@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.

yimsiokek · ‎07-03-2018

@Matt Clarke do you have any suggestion? Thanks in advance

yimsiokek · ‎07-03-2018

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?

yimsiokek · ‎11-24-2017

@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

yimsiokek · ‎11-23-2017

@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?

yimsiokek · ‎11-23-2017

Yes, if you keberized your cluster

yimsiokek · ‎11-22-2017

@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>";; };

yimsiokek · ‎11-22-2017

@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 🙂

Online	Offline
Last Visited	‎08-31-2021 07:34 AM

Date Registered	‎07-19-2017 02:53 AM
Last Visited	‎08-31-2021 07:34 AM
Total Messages Posted	14
Total Kudos Received	1

Re: Hbase Thrift server failed on scanning table

Re: NiFi 1.4 ConsumeMQTT Processor throws an error...

Re: How to get Nifi invokehttp SSL works in apache...

Re: How to get Nifi invokehttp SSL works in apache...

How to get Nifi invokehttp SSL works in apache nif...

Re: Console producer/consumer not working in kafka...

Re: Can NiFi connect to OPC DA and HDA..??

Re: Console producer/consumer not working in kafka...

Re: Console producer/consumer not working in kafka...

Re: Failed to compile nifi-opcua-service while 'mv...