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
