question Re: NPE if kafka has null record key in Support Questions

NPE if kafka has null record key

buntu — Fri, 16 Sep 2022 09:19:14 GMT

I'm using the patch from FLUME-2578 but when I pass the patched jar via --classpath option of flume-ng, I see the old jar being used instead of the patched jar since it is being appended.

Is there a way to override or append the patched jar to java classpath and run flume agent?

Thanks!

Re: NPE if kafka has null record key

joey — Thu, 15 Jan 2015 21:24:50 GMT

I'm not aware of an option to get it added to the classpath first.

In the past when I've had to deploy a patched jar to a core component,
I replace the jar file in the lib directory.

Re: NPE if kafka has null record key

buntu — Thu, 15 Jan 2015 21:57:17 GMT

Thanks Joey, looks like "/usr/bin/flume-ng agent ... -Duser.home=/user/xyz -c /path/to/jar1:/path/to/jar2" seem to have done the trick by prepending to the java.class.path.