Member since
07-05-2021
3
Posts
0
Kudos Received
0
Solutions
07-13-2021
12:53 AM
I am using Nifi with Local setup . I am using 'consumeKafka' Processor In configuration I am specifying Kafka broker : Client_specified_broker , Security Protocol : SASL_SSL , SASL Mechanism : Plain , Username : SSL username , Password : SSL password , SSL Context Service : StandardSSLContextService , Topic : Topic From which data is consumed , Group_id : test I dont see any keystore or truststore credentials with Confluent Kafka broker I am using . How to configure ConsumeKafka Processor and also please let me know if there are any setting to be done with Nifi so that it could read messages from SSL encrypted Kafka broker
... View more
Labels:
- Labels:
-
Apache Kafka
-
Apache NiFi
07-05-2021
04:37 AM
ERROR [Timer-Driven Process Thread-8] o.a.n.p.kafka.pubsub.ConsumeKafka_2_6 ConsumeKafka_2_6[id=62dd55d9-017a-1000-39e8-6fc150e705d4] Exception while processing data from kafka so will close the lease org.apache.nifi.processors.kafka.pubsub.ConsumerPool$SimpleConsumerLease@75158887 due to java.lang.OutOfMemoryError: Java heap space: java.lang.OutOfMemoryError: Java heap space java.lang.OutOfMemoryError: Java heap space
... View more
Labels:
- Labels:
-
Apache NiFi