This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 709bfc506a9 KAFKA-18641: AsyncKafkaConsumer could lose records with
auto offset commit (#18737)
add acea35ddf38 MINOR: cleanup SinkNode generics (#18975)
No new revisions were added by this update.
Summary of changes:
.../kstream/internals/WrappingNullableUtils.java | 34 ++++++++++------------
.../streams/processor/internals/SinkNode.java | 5 ++--
.../streams/processor/internals/SourceNode.java | 4 +--
.../streams/processor/internals/SinkNodeTest.java | 10 +++----
.../processor/internals/SourceNodeTest.java | 6 ++--
5 files changed, 28 insertions(+), 31 deletions(-)
