kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch trunk updated (0de61a4 -> a5a6938)
Date Mon, 07 Oct 2019 08:02:37 GMT
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 0de61a4  KAFKA-8885; The Kafka Protocol should Support Optional Tagged Fields (#7325)
     add a5a6938  KAFKA-8233: TopologyTestDriver test input and output usability improvements
(#7378)

No new revisions were added by this update.

Summary of changes:
 build.gradle                                       |   1 +
 docs/streams/developer-guide/testing.html          |  95 +++--
 .../streams/examples/wordcount/WordCountDemo.java  |  20 +-
 .../examples/docs/DeveloperGuideTesting.java       | 187 ++++++++++
 .../examples/wordcount/WordCountDemoTest.java      | 112 ++++++
 .../apache/kafka/streams/StreamsBuilderTest.java   |  50 ++-
 .../KStreamTransformIntegrationTest.java           |  10 +-
 .../kstream/internals/AbstractStreamTest.java      |   6 +-
 .../kstream/internals/GlobalKTableJoinsTest.java   |  15 +-
 .../kstream/internals/KGroupedStreamImplTest.java  |  88 +++--
 .../kstream/internals/KGroupedTableImplTest.java   |  32 +-
 .../kstream/internals/KStreamBranchTest.java       |   6 +-
 .../kstream/internals/KStreamFilterTest.java       |   9 +-
 .../kstream/internals/KStreamFlatMapTest.java      |  10 +-
 .../internals/KStreamFlatMapValuesTest.java        |  18 +-
 .../kstream/internals/KStreamForeachTest.java      |   6 +-
 .../internals/KStreamGlobalKTableJoinTest.java     |  22 +-
 .../internals/KStreamGlobalKTableLeftJoinTest.java |  22 +-
 .../streams/kstream/internals/KStreamImplTest.java | 100 +++--
 .../kstream/internals/KStreamKStreamJoinTest.java  | 161 ++++----
 .../internals/KStreamKStreamLeftJoinTest.java      |  57 +--
 .../kstream/internals/KStreamKTableJoinTest.java   |  23 +-
 .../internals/KStreamKTableLeftJoinTest.java       |  19 +-
 .../streams/kstream/internals/KStreamMapTest.java  |  10 +-
 .../kstream/internals/KStreamMapValuesTest.java    |  12 +-
 .../streams/kstream/internals/KStreamPeekTest.java |   6 +-
 .../kstream/internals/KStreamSelectKeyTest.java    |  10 +-
 .../kstream/internals/KStreamTransformTest.java    |  27 +-
 .../internals/KStreamTransformValuesTest.java      |  12 +-
 .../internals/KStreamWindowAggregateTest.java      | 161 ++++----
 .../kstream/internals/KTableAggregateTest.java     |  83 +++--
 .../kstream/internals/KTableFilterTest.java        |  86 +++--
 .../streams/kstream/internals/KTableImplTest.java  |  18 +-
 .../internals/KTableKTableInnerJoinTest.java       | 170 +++++----
 .../internals/KTableKTableLeftJoinTest.java        | 192 +++++-----
 .../internals/KTableKTableOuterJoinTest.java       | 185 ++++-----
 .../kstream/internals/KTableMapKeysTest.java       |   8 +-
 .../kstream/internals/KTableMapValuesTest.java     |  64 ++--
 .../kstream/internals/KTableSourceTest.java        |  80 ++--
 .../internals/KTableTransformValuesTest.java       |  38 +-
 .../internals/SessionWindowedKStreamImplTest.java  |  16 +-
 .../kstream/internals/SuppressScenarioTest.java    | 197 +++++-----
 .../internals/TimeWindowedKStreamImplTest.java     |  16 +-
 .../processor/internals/ProcessorTopologyTest.java | 339 +++++++++--------
 .../state/internals/CachingWindowStoreTest.java    |  31 +-
 .../kafka/streams/scala/kstream/KStreamTest.scala  |  73 ++--
 .../kafka/streams/scala/kstream/KTableTest.scala   | 176 +++++----
 .../kafka/streams/scala/utils/TestDriver.scala     |  23 +-
 .../org/apache/kafka/streams/TestInputTopic.java   | 256 +++++++++++++
 .../org/apache/kafka/streams/TestOutputTopic.java  | 198 ++++++++++
 .../apache/kafka/streams/TopologyTestDriver.java   | 306 +++++++++++----
 .../kafka/streams/test/ConsumerRecordFactory.java  |   4 +
 .../apache/kafka/streams/test/OutputVerifier.java  |   4 +
 .../org/apache/kafka/streams/test/TestRecord.java  | 250 +++++++++++++
 .../org/apache/kafka/streams/TestTopicsTest.java   | 412 +++++++++++++++++++++
 .../kafka/streams/TopologyTestDriverTest.java      | 338 +++++++++++------
 .../streams/test/ConsumerRecordFactoryTest.java    |   1 +
 .../kafka/streams/test/OutputVerifierTest.java     |   1 +
 .../apache/kafka/streams/test/TestRecordTest.java  | 168 +++++++++
 59 files changed, 3595 insertions(+), 1445 deletions(-)
 create mode 100644 streams/examples/src/test/java/org/apache/kafka/streams/examples/docs/DeveloperGuideTesting.java
 create mode 100644 streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountDemoTest.java
 create mode 100644 streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java
 create mode 100644 streams/test-utils/src/main/java/org/apache/kafka/streams/TestOutputTopic.java
 create mode 100644 streams/test-utils/src/main/java/org/apache/kafka/streams/test/TestRecord.java
 create mode 100644 streams/test-utils/src/test/java/org/apache/kafka/streams/TestTopicsTest.java
 create mode 100644 streams/test-utils/src/test/java/org/apache/kafka/streams/test/TestRecordTest.java


Mime
View raw message