NPE if kafka has null record key

[#1]

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!

[#2]

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.

[#3 · Accepted solution]

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.