The unit tests in KTableSuppressProcessorTest use the MockProcessorContext, which does not have a mocked record collector, by design. We said that if you want to use it, you have to disable logging in your stores under test.
We can change the MockProcessorContext, but it requires a KIP. For now, that test directly instantiates the KTableSuppressProcessor and also the Buffer (using the store builder), so it's very straightforward for it to call `withLoggingDisabled` during that construction. For the scenario test, which uses the TopologyTestDriver, and obviously for the integration tests, their contexts do support record collection, and therefore everything works fine with the default of changelogging enabled. [ Full content available at: https://github.com/apache/kafka/pull/5724 ] This message was relayed via gitbox.apache.org for [email protected]
