@yusup: did you find out if you were getting retries?

hi Lucas, not yet .

I started fresh again and I am having this error.

Are you using a local zookeeper or a remote one?

All are on google cloud platform.

Ah k. But on the same network then.

yes.

I had working version , I think this is second time I encounter this error after I updated deps etc.

Hmm. Might be worth resetting the offset using the option in the Kafka input task map, assuming you've done more than one run with this zookeeper. Otherwise, I'm not sure. I'm off to sleep so can't help much more atm

working version meaning , onyx ,kafka all were functioning correctly.

ok

Good night man.