You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by vv...@apache.org on 2020/08/27 17:39:23 UTC

[kafka] branch kip-478-part-4 updated (662f0ae -> 34d0db7)

This is an automated email from the ASF dual-hosted git repository.

vvcephei pushed a change to branch kip-478-part-4
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 662f0ae  update
     add 08a8bf0  tweak
     add 34d0db7  finalizing the proposal and renaming the adapters for clarity

No new revisions were added by this update.

Summary of changes:
 .../internals/InternalApiProcessorContext.java     |  3 +-
 ...> InternalProcessorContextNewToOldAdapter.java} | 12 ++++----
 ...> InternalProcessorContextOldToNewAdapter.java} | 10 +++----
 .../processor/internals/ProcessorAdapter.java      |  2 +-
 ...r.java => ProcessorContextNewToOldAdapter.java} | 35 ++++++++--------------
 .../streams/processor/internals/ProcessorNode.java |  2 +-
 .../java/org/apache/kafka/test/MockProcessor.java  |  4 +--
 .../kafka/streams/MockApiProcessorContextTest.java |  8 +----
 8 files changed, 29 insertions(+), 47 deletions(-)
 rename streams/src/main/java/org/apache/kafka/streams/processor/internals/{InternalProcessorContextReverseAdapter.java => InternalProcessorContextNewToOldAdapter.java} (92%)
 rename streams/src/main/java/org/apache/kafka/streams/processor/internals/{ProcessorContextAdapter.java => InternalProcessorContextOldToNewAdapter.java} (94%)
 rename streams/src/main/java/org/apache/kafka/streams/processor/internals/{ProcessorContextReverseAdapter.java => ProcessorContextNewToOldAdapter.java} (75%)