needed to change, looks like the result of a bad cherry-pick maybe? The `0.11.0` branch has the constructor of `public RecordCollectorImpl(final Producer<byte[], byte[]> producer, final String streamTaskId)`
[ Full content available at: https://github.com/apache/kafka/pull/5613 ] This message was relayed via gitbox.apache.org for [email protected]
