I'm not sure what this test was previously checking for. It looks like it wanted to try updating without previously initializing the task.
This was previously throwing an NPE wrapped in a ProcessorStateException when the adapted callback actually tried to dereference the (null) wrapped callback. Now, the NPE is surfaced a little earlier, not guarded by the ProcessorStateException try/catch. I think this is still ok, so I've just refined the test to be more specific. [ Full content available at: https://github.com/apache/kafka/pull/5710 ] This message was relayed via gitbox.apache.org for [email protected]
