You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@nifi.apache.org by varuntango <va...@tangotech.co.in> on 2020/11/01 13:54:37 UTC
NiFi sasl communication issue with oracle streaming kafka
Hi,
Im trying to access kafka from nifi installed on oracle server. While i try
to access broker with sasl plaintext manner, while i cant be able to receive
data. Here i have mentioned processor configuration and stack trace of
information. please help me out from this issue;
<http://apache-nifi-users-list.2361937.n4.nabble.com/file/t1025/aaa.png>
2020-10-31 11:19:11,695 WARN [Timer-Driven Process Thread-7]
org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-3,
groupId=hellostage3audit] Connection to node -1 terminated during
authentication. This may indicate that authentication failed due to invalid
credentials.
2020-10-31 11:19:12,601 WARN [Timer-Driven Process Thread-7]
org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-3,
groupId=hellostage3audit] Connection to node -1 terminated during
authentication. This may indicate that authentication failed due to invalid
credentials.
2020-10-31 11:19:13,506 WARN [Timer-Driven Process Thread-7]
org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-3,
groupId=hellostage3audit] Connection to node -1 terminated during
authentication. This may indicate that authentication failed due to invalid
credentials.
2020-10-31 11:19:14,545 WARN [Timer-Driven Process Thread-7]
org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-3,
groupId=hellostage3audit] Connection to node -1 terminated during
authentication. This may indicate that authentication failed due to invalid
credentials.
2020-10-31 11:19:15,403 WARN [Timer-Driven Process Thread-7]
org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-3,
groupId=hellostage3audit] Connection to node -1 terminated during
authentication. This may indicate that authentication failed due to invalid
credentials.
2020-10-31 11:19:16,560 WARN [Timer-Driven Process Thread-7]
org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-3,
groupId=hellostage3audit] Connection to node -1 terminated during
authentication. This may indicate that authentication failed due to invalid
credentials.
2020-10-31 11:19:17,767 WARN [Timer-Driven Process Thread-7]
org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-3,
groupId=hellostage3audit] Connection to node -1 terminated during
authentication. This may indicate that authentication failed due to invalid
credentials.
2020-10-31 11:19:18,675 WARN [Timer-Driven Process Thread-7]
org.apache.kafka.clients.NetworkClient [Consumer clientId=consumer-3,
groupId=hellostage3audit] Connection to node -1 terminated during
authentication. This may indicate that authentication failed due to invalid
credentials.
--
Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/
Re: NiFi sasl communication issue with oracle streaming kafka
Posted by varuntango <va...@tangotech.co.in>.
Thanks Bryan, Yeah its working fine. when i try to change offset_reset into
earliest type. I can able to get data.
--
Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/
Re: NiFi sasl communication issue with oracle streaming kafka
Posted by Bryan Bende <bb...@gmail.com>.
Hello,
There is nothing that shows an error here. The second half of the log shows
successfully joining the consumer group and being assigned a partition.
Do you have new data actively being published to the topic?
The default behavior is to start consuming new data from the current point
in time, so you won’t get anything unless new data is being published.
You can change offset reset to earliest to start from beginning, but also
make sure to change the group id, since its it is only used when the group
is established.
Thanks,
Bryan
On Mon, Nov 2, 2020 at 8:12 PM varuntango <va...@tangotech.co.in> wrote:
> Now, I can upgrade version of nifi 1.12.1 below error kind of "(id
> :2123232
> rack:null)" Kindly have a look at the stacktrace of information, please
> anyone from this fourm help me out im stuck on this issue past two days,
>
> 2020-11-03 01:09:58,079 INFO [Timer-Driven Process Thread-5]
> o.a.k.c.s.authenticator.AbstractLogin Successfully logged in.
> 2020-11-03 01:09:58,518 INFO [Timer-Driven Process Thread-5]
> o.a.kafka.common.utils.AppInfoParser Kafka version : 2.0.0
> 2020-11-03 01:09:58,518 INFO [Timer-Driven Process Thread-5]
> o.a.kafka.common.utils.AppInfoParser Kafka commitId : 3402a8361b734732
> 2020-11-03 01:10:00,520 INFO [Timer-Driven Process Thread-5]
> org.apache.kafka.clients.Metadata Cluster ID: OSS
> 2020-11-03 01:10:00,533 INFO [Timer-Driven Process Thread-5]
> o.a.k.c.c.internals.AbstractCoordinator [Consumer clientId=consumer-1,
> groupId=hlloadsfs] Discovered group coordinator xxxxxxx:9092 (id:
> 2147483647
> rack: null)
> 2020-11-03 01:10:00,593 INFO [Timer-Driven Process Thread-5]
> o.a.k.c.c.internals.ConsumerCoordinator [Consumer clientId=consumer-1,
> groupId=hlloadsfs] Revoking previously assigned partitions []
> 2020-11-03 01:10:00,593 INFO [Timer-Driven Process Thread-5]
> o.a.k.c.c.internals.AbstractCoordinator [Consumer clientId=consumer-1,
> groupId=hlloadsfs] (Re-)joining group
> 2020-11-03 01:10:00,737 INFO [NiFi Web Server-21]
> o.a.n.c.s.StandardProcessScheduler Stopping
> ConsumeKafkaRecord_2_0[id=87b56653-0175-1000-c24f-a85eee7d7acc]
> 2020-11-03 01:10:00,737 INFO [NiFi Web Server-21]
> o.a.n.controller.StandardProcessorNode Stopping processor:
> ConsumeKafkaRecord_2_0[id=87b56653-0175-1000-c24f-a85eee7d7acc]
> 2020-11-03 01:10:00,740 INFO [Timer-Driven Process Thread-3]
> o.a.n.c.s.TimerDrivenSchedulingAgent Stopped scheduling
> ConsumeKafkaRecord_2_0[id=87b56653-0175-1000-c24f-a85eee7d7acc] to run
> 2020-11-03 01:10:00,834 INFO [Timer-Driven Process Thread-5]
> o.a.k.c.c.internals.AbstractCoordinator [Consumer clientId=consumer-1,
> groupId=hlloadsfs] Successfully joined group with generation 3
> 2020-11-03 01:10:00,837 INFO [Timer-Driven Process Thread-5]
> o.a.k.c.c.internals.ConsumerCoordinator [Consumer clientId=consumer-1,
> groupId=hlloadsfs] Setting newly assigned partitions [devtest-0]
> 2020-11-03 01:10:01,038 INFO [Flow Service Tasks Thread-1]
> o.a.nifi.controller.StandardFlowService Saved flow controller
> org.apache.nifi.controller.FlowController@2394f1b // Another save pending
> =
> false
>
>
>
>
> --
> Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/
>
--
Sent from Gmail Mobile
Re: NiFi sasl communication issue with oracle streaming kafka
Posted by varuntango <va...@tangotech.co.in>.
Now, I can upgrade version of nifi 1.12.1 below error kind of "(id :2123232
rack:null)" Kindly have a look at the stacktrace of information, please
anyone from this fourm help me out im stuck on this issue past two days,
2020-11-03 01:09:58,079 INFO [Timer-Driven Process Thread-5]
o.a.k.c.s.authenticator.AbstractLogin Successfully logged in.
2020-11-03 01:09:58,518 INFO [Timer-Driven Process Thread-5]
o.a.kafka.common.utils.AppInfoParser Kafka version : 2.0.0
2020-11-03 01:09:58,518 INFO [Timer-Driven Process Thread-5]
o.a.kafka.common.utils.AppInfoParser Kafka commitId : 3402a8361b734732
2020-11-03 01:10:00,520 INFO [Timer-Driven Process Thread-5]
org.apache.kafka.clients.Metadata Cluster ID: OSS
2020-11-03 01:10:00,533 INFO [Timer-Driven Process Thread-5]
o.a.k.c.c.internals.AbstractCoordinator [Consumer clientId=consumer-1,
groupId=hlloadsfs] Discovered group coordinator xxxxxxx:9092 (id: 2147483647
rack: null)
2020-11-03 01:10:00,593 INFO [Timer-Driven Process Thread-5]
o.a.k.c.c.internals.ConsumerCoordinator [Consumer clientId=consumer-1,
groupId=hlloadsfs] Revoking previously assigned partitions []
2020-11-03 01:10:00,593 INFO [Timer-Driven Process Thread-5]
o.a.k.c.c.internals.AbstractCoordinator [Consumer clientId=consumer-1,
groupId=hlloadsfs] (Re-)joining group
2020-11-03 01:10:00,737 INFO [NiFi Web Server-21]
o.a.n.c.s.StandardProcessScheduler Stopping
ConsumeKafkaRecord_2_0[id=87b56653-0175-1000-c24f-a85eee7d7acc]
2020-11-03 01:10:00,737 INFO [NiFi Web Server-21]
o.a.n.controller.StandardProcessorNode Stopping processor:
ConsumeKafkaRecord_2_0[id=87b56653-0175-1000-c24f-a85eee7d7acc]
2020-11-03 01:10:00,740 INFO [Timer-Driven Process Thread-3]
o.a.n.c.s.TimerDrivenSchedulingAgent Stopped scheduling
ConsumeKafkaRecord_2_0[id=87b56653-0175-1000-c24f-a85eee7d7acc] to run
2020-11-03 01:10:00,834 INFO [Timer-Driven Process Thread-5]
o.a.k.c.c.internals.AbstractCoordinator [Consumer clientId=consumer-1,
groupId=hlloadsfs] Successfully joined group with generation 3
2020-11-03 01:10:00,837 INFO [Timer-Driven Process Thread-5]
o.a.k.c.c.internals.ConsumerCoordinator [Consumer clientId=consumer-1,
groupId=hlloadsfs] Setting newly assigned partitions [devtest-0]
2020-11-03 01:10:01,038 INFO [Flow Service Tasks Thread-1]
o.a.nifi.controller.StandardFlowService Saved flow controller
org.apache.nifi.controller.FlowController@2394f1b // Another save pending =
false
--
Sent from: http://apache-nifi-users-list.2361937.n4.nabble.com/