> Configure project : Building project 'core' with Scala version 2.13.3 Building project 'streams-scala' with Scala version 2.13.3 > Task :generator:compileJava UP-TO-DATE > Task :generator:processResources NO-SOURCE > Task :generator:classes UP-TO-DATE > Task :clients:processMessages UP-TO-DATE > Task :clients:compileJava UP-TO-DATE > Task :clients:processResources UP-TO-DATE > Task :clients:classes UP-TO-DATE > Task :clients:determineCommitId UP-TO-DATE > Task :clients:createVersionFile > Task :clients:jar UP-TO-DATE > Task :clients:processTestMessages UP-TO-DATE > Task :clients:compileTestJava UP-TO-DATE > Task :clients:processTestResources UP-TO-DATE > Task :clients:testClasses UP-TO-DATE > Task :streams:processMessages UP-TO-DATE > Task :connect:api:compileJava UP-TO-DATE > Task :connect:api:processResources NO-SOURCE > Task :connect:api:classes UP-TO-DATE > Task :connect:api:copyDependantLibs UP-TO-DATE > Task :connect:api:jar UP-TO-DATE > Task :connect:json:compileJava UP-TO-DATE > Task :connect:json:processResources NO-SOURCE > Task :connect:json:classes UP-TO-DATE > Task :connect:json:copyDependantLibs UP-TO-DATE > Task :connect:json:jar UP-TO-DATE > Task :streams:compileJava UP-TO-DATE > Task :streams:processResources UP-TO-DATE > Task :streams:classes UP-TO-DATE > Task :raft:processMessages UP-TO-DATE > Task :raft:compileJava UP-TO-DATE > Task :raft:processResources UP-TO-DATE > Task :raft:classes UP-TO-DATE > Task :raft:determineCommitId UP-TO-DATE > Task :raft:createVersionFile > Task :raft:jar UP-TO-DATE > Task :core:compileJava UP-TO-DATE > Task :core:compileScala UP-TO-DATE > Task :core:processResources NO-SOURCE > Task :core:classes UP-TO-DATE > Task :core:copyDependantLibs UP-TO-DATE > Task :core:jar UP-TO-DATE > Task :core:compileTestJava NO-SOURCE > Task :core:compileTestScala UP-TO-DATE > Task :core:processTestResources UP-TO-DATE > Task :core:testClasses UP-TO-DATE > Task :streams:copyDependantLibs UP-TO-DATE > Task :streams:determineCommitId UP-TO-DATE > Task :streams:createStreamsVersionFile > Task :streams:jar UP-TO-DATE > Task :streams:test-utils:compileJava UP-TO-DATE > Task :streams:test-utils:processResources NO-SOURCE > Task :streams:test-utils:classes UP-TO-DATE > Task :streams:test-utils:checkstyleMain UP-TO-DATE > Task :streams:test-utils:compileTestJava UP-TO-DATE > Task :streams:test-utils:processTestResources UP-TO-DATE > Task :streams:test-utils:testClasses UP-TO-DATE > Task :streams:test-utils:checkstyleTest UP-TO-DATE > Task :streams:test-utils:spotbugsMain UP-TO-DATE > Task :streams:test-utils:test org.apache.kafka.streams.test.TestRecordTest > testConsumerRecord PASSED org.apache.kafka.streams.test.TestRecordTest > testToString PASSED org.apache.kafka.streams.test.TestRecordTest > testInvalidRecords PASSED org.apache.kafka.streams.test.TestRecordTest > testPartialConstructorEquals PASSED org.apache.kafka.streams.test.TestRecordTest > testMultiFieldMatcher PASSED org.apache.kafka.streams.test.TestRecordTest > testFields PASSED org.apache.kafka.streams.test.TestRecordTest > testProducerRecord PASSED org.apache.kafka.streams.test.TestRecordTest > testEqualsAndHashCode PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentWithNullForCompareKeyValue PASSED org.apache.kafka.streams.test.MockProcessorContextAPITest > shouldStoreAndReturnStateStores PASSED org.apache.kafka.streams.test.MockProcessorContextAPITest > shouldCaptureOutputRecords PASSED org.apache.kafka.streams.test.MockProcessorContextAPITest > fullConstructorShouldSetAllExpectedAttributes PASSED org.apache.kafka.streams.test.MockProcessorContextAPITest > shouldCaptureCommitsAndAllowReset PASSED org.apache.kafka.streams.test.MockProcessorContextAPITest > shouldCaptureApplicationAndRecordMetadata PASSED org.apache.kafka.streams.test.MockProcessorContextAPITest > shouldCaptureRecordsOutputToChildByName PASSED org.apache.kafka.streams.test.MockProcessorContextAPITest > shouldCapturePunctuator PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullReverseForCompareValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfValueIsEqualForCompareValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentForCompareKeyValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullExpectedRecordForCompareValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfTimestampDifferentWithNullReverseForCompareValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProducerRecordWithExpectedRecordForCompareValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentForCompareValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfKeyAndValueIsEqualWithNullForCompareKeyValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullForCompareValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfValueAndTimestampIsEqualWithNullForCompareValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullForCompareKeyValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentWithNullForCompareKeyValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentForCompareKeyValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullForCompareKeyValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfTimestampIsDifferentForCompareValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfKeyAndValueIsEqualForCompareKeyValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareKeyValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfKeyAndValueIsEqualWithNullForCompareKeyValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfValueAndTimestampIsEqualForCompareValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullExpectedRecordForCompareKeyValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentForCompareValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullReversForCompareKeyValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullExpectedRecordForCompareKeyValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentForCompareValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfValueIsEqualForCompareValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProducerRecordWithExpectedRecordForCompareKeyValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentForCompareKeyValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProducerRecordWithExpectedRecordForCompareKeyValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentWithNullForCompareKeyValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfKeyAndValueAndTimestampIsEqualForCompareKeyValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfValueIsEqualWithNullForCompareValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfValueAndTimestampIsEqualWithNullForCompareValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullForCompareValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullForCompareValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfKeyAndValueIsEqualForCompareKeyValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentForCompareKeyValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentForCompareValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullForCompareValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentForCompareKeyValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentForCompareKeyValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfValueIsEqualWithNullForCompareValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullReverseForCompareValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullReverseForCompareValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfTimestampIsDifferentForCompareValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfKeyAndValueAndTimestampIsEqualWithNullForCompareKeyValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullForCompareKeyValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentForCompareKeyValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProducerRecordWithExpectedRecordForCompareValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullExpectedRecordForCompareValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareKeyValue PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfKeyAndValueAndTimestampIsEqualForCompareKeyValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfKeyAndValueIsEqualWithNullForCompareKeyValueWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfKeyIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentForCompareKeyValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfValueAndTimestampIsEqualForCompareValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestamp PASSED org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullReverseForCompareValueTimestampWithProducerRecord PASSED org.apache.kafka.streams.test.wordcount.WindowedWordCountProcessorTest > shouldWorkWithInMemoryStore PASSED org.apache.kafka.streams.internals.WindowStoreFacadeTest > shouldReturnIsOpen PASSED org.apache.kafka.streams.internals.WindowStoreFacadeTest > shouldReturnName PASSED org.apache.kafka.streams.internals.WindowStoreFacadeTest > shouldPutWithUnknownTimestamp PASSED org.apache.kafka.streams.internals.WindowStoreFacadeTest > shouldPutWindowStartTimestampWithUnknownTimestamp PASSED org.apache.kafka.streams.MockProcessorContextTest > shouldStoreAndReturnStateStores PASSED org.apache.kafka.streams.MockProcessorContextTest > shouldCaptureOutputRecordsUsingTo PASSED org.apache.kafka.streams.MockProcessorContextTest > shouldCaptureOutputRecords PASSED org.apache.kafka.streams.internals.WindowStoreFacadeTest > shouldReturnIsPersistent PASSED org.apache.kafka.streams.MockProcessorContextTest > fullConstructorShouldSetAllExpectedAttributes PASSED org.apache.kafka.streams.MockProcessorContextTest > shouldCaptureCommitsAndAllowReset PASSED org.apache.kafka.streams.MockProcessorContextTest > shouldThrowIfForwardedWithDeprecatedChildName PASSED org.apache.kafka.streams.MockProcessorContextTest > shouldThrowIfForwardedWithDeprecatedChildIndex PASSED org.apache.kafka.streams.MockProcessorContextTest > shouldCaptureApplicationAndRecordMetadata PASSED org.apache.kafka.streams.MockProcessorContextTest > shouldCaptureRecordsOutputToChildByName PASSED org.apache.kafka.streams.MockProcessorContextTest > shouldCapturePunctuator PASSED org.apache.kafka.streams.internals.WindowStoreFacadeTest > shouldForwardDeprecatedInit PASSED org.apache.kafka.streams.internals.WindowStoreFacadeTest > shouldForwardClose PASSED org.apache.kafka.streams.internals.WindowStoreFacadeTest > shouldForwardFlush PASSED org.apache.kafka.streams.internals.WindowStoreFacadeTest > shouldForwardInit PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCloseProcessor[Eos enabled = true] PASSED org.apache.kafka.streams.test.wordcount.WindowedWordCountProcessorTest > shouldWorkWithPersistentStore PASSED org.apache.kafka.streams.TestTopicsTest > testNonUsedOutputTopic PASSED org.apache.kafka.streams.TestTopicsTest > testEmptyTopic PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@345b6621, timestamped = true, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@51b3c83f, timestamped = true, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@3eb6c646, timestamped = true, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@20d0c8d7, timestamped = true, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@28da1b2a, timestamped = true, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@67e7cc3e, timestamped = true, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@6febb272, timestamped = true, caching = false, logging = true] PASSED org.apache.kafka.streams.TestTopicsTest > testStartTimestamp PASSED org.apache.kafka.streams.TestTopicsTest > testNegativeAdvance PASSED org.apache.kafka.streams.TestTopicsTest > shouldNotAllowToCreateWithNullDriver PASSED org.apache.kafka.streams.TestTopicsTest > testDuration PASSED org.apache.kafka.streams.TestTopicsTest > testOutputToString PASSED org.apache.kafka.streams.TestTopicsTest > testValue PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@495b4928, timestamped = true, caching = false, logging = true] PASSED org.apache.kafka.streams.TestTopicsTest > testTimestampAutoAdvance PASSED org.apache.kafka.streams.TestTopicsTest > testOutputWrongSerde PASSED org.apache.kafka.streams.TestTopicsTest > shouldNotAllowToCreateOutputTopicWithNullTopicName PASSED org.apache.kafka.streams.TestTopicsTest > testWrongSerde PASSED org.apache.kafka.streams.TestTopicsTest > testKeyValuesToMapWithNull PASSED org.apache.kafka.streams.TestTopicsTest > testNonExistingOutputTopic PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldFeedStoreFromGlobalKTable[Eos enabled = true] PASSED org.apache.kafka.streams.TestTopicsTest > testMultipleTopics PASSED org.apache.kafka.streams.TestTopicsTest > testKeyValueList PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@31201862, timestamped = true, caching = false, logging = true] PASSED org.apache.kafka.streams.TestTopicsTest > shouldNotAllowToCreateOutputWithNullDriver PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@68ffb444, timestamped = true, caching = false, logging = false] PASSED org.apache.kafka.streams.TestTopicsTest > testValueList PASSED org.apache.kafka.streams.TestTopicsTest > testRecordList PASSED org.apache.kafka.streams.TestTopicsTest > testNonExistingInputTopic PASSED org.apache.kafka.streams.TestTopicsTest > testKeyValuesToMap PASSED org.apache.kafka.streams.TestTopicsTest > testRecordsToList PASSED org.apache.kafka.streams.TestTopicsTest > testKeyValueListDuration PASSED org.apache.kafka.streams.TestTopicsTest > testInputToString PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@5a35f30b, timestamped = true, caching = false, logging = false] PASSED org.apache.kafka.streams.TestTopicsTest > testTimestamp PASSED org.apache.kafka.streams.TestTopicsTest > testWithHeaders PASSED org.apache.kafka.streams.TestTopicsTest > testKeyValue PASSED org.apache.kafka.streams.TestTopicsTest > shouldNotAllowToCreateTopicWithNullTopicName PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilder@4934e36c, timestamped = true, caching = false, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@78660120, timestamped = false, caching = true, logging = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCleanUpPersistentStateStoresOnClose[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowForUnknownTopicDeprecated[Eos enabled = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@6d2ed7fc, timestamped = false, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@1876ccf9, timestamped = false, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@76b76318, timestamped = false, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@3e1013ef, timestamped = false, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@251ab2e6, timestamped = false, caching = true, logging = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowPatternNotValidForTopicNameException[Eos enabled = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@ba5b3b8, timestamped = false, caching = false, logging = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldEnqueueLaterOutputsAfterEarlierOnes[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldUseSourceSpecificDeserializersDeprecated[Eos enabled = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@4647be77, timestamped = false, caching = false, logging = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPunctuateIfEvenTimeAdvances[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowNoSuchElementExceptionForUnusedOutputTopicWithDynamicRouting[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldInitProcessor[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowForUnknownTopic[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPunctuateOnStreamsTime[Eos enabled = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@7876523b, timestamped = false, caching = false, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@88b4251, timestamped = false, caching = false, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@2e95188b, timestamped = false, caching = false, logging = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCaptureGlobalTopicNameIfWrittenInto[Eos enabled = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.KeyValueStoreBuilder@555abf28, timestamped = false, caching = false, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@1ff7c832, timestamped = true, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4dbc8857, timestamped = true, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4beb902b, timestamped = true, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4b48c581, timestamped = true, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@6adf2282, timestamped = true, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4388e1be, timestamped = true, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@54f55b2c, timestamped = true, caching = false, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@599ce8fe, timestamped = true, caching = false, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4ac40a7d, timestamped = true, caching = false, logging = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowIfInMemoryBuiltInStoreIsAccessedWithUntypedMethod[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldProcessFromSourcesThatMatchMultiplePattern[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPopulateGlobalStore[Eos enabled = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@4ec5978a, timestamped = true, caching = false, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@30979945, timestamped = true, caching = false, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@e724cb1, timestamped = true, caching = false, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@648f28e0, timestamped = false, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@6148a3c, timestamped = false, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@a45660a, timestamped = false, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@164eb437, timestamped = false, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@b1b5636, timestamped = false, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@29fc6803, timestamped = false, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@8a82e00, timestamped = false, caching = false, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@6b24cc2e, timestamped = false, caching = false, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@3adf8d9a, timestamped = false, caching = false, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@70a946b2, timestamped = false, caching = false, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@3938ae89, timestamped = false, caching = false, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.WindowStoreBuilder@7430403c, timestamped = false, caching = false, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.SessionStoreBuilder@3245b07d, timestamped = false, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.SessionStoreBuilder@863fc51, timestamped = false, caching = true, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.SessionStoreBuilder@74534732, timestamped = false, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.SessionStoreBuilder@214c824, timestamped = false, caching = true, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.SessionStoreBuilder@1dcd4643, timestamped = false, caching = false, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.SessionStoreBuilder@adba0df, timestamped = false, caching = false, logging = true] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.SessionStoreBuilder@64df1c61, timestamped = false, caching = false, logging = false] PASSED org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > shouldEitherInitOrThrow[builder = org.apache.kafka.streams.state.internals.SessionStoreBuilder@40aead36, timestamped = false, caching = false, logging = false] PASSED org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldReturnIsOpen PASSED org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldDeleteAndReturnPlainValue PASSED org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldReturnName PASSED org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldPutWithUnknownTimestamp PASSED org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldPutAllWithUnknownTimestamp PASSED org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldReturnIsPersistent PASSED org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldForwardDeprecatedInit PASSED org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldPutIfAbsentWithUnknownTimestamp PASSED org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldForwardClose PASSED org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldForwardFlush PASSED org.apache.kafka.streams.internals.KeyValueStoreFacadeTest > shouldForwardInit PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowIfPersistentBuiltInStoreIsAccessedWithUntypedMethod[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldAllowPrePopulatingStatesStoresWithCachingEnabled[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldReturnCorrectPersistentStoreTypeOnly[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldRespectTaskIdling[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldUseSourceSpecificDeserializers[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldReturnAllStores[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldNotCreateStateDirectoryForStatelessTopology[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldReturnAllStoresNames[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPassRecordHeadersIntoSerializersAndDeserializers[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldProcessConsumerRecordList[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldUseSinkSpecificSerializers[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldFlushStoreForFirstInput[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldProcessFromSourceThatMatchPattern[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCaptureSinkTopicNamesIfWrittenInto[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldUpdateStoreForNewKey[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldSendRecordViaCorrectSourceTopicDeprecated[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPunctuateOnWallClockTime[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldSetRecordMetadata[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldNotUpdateStoreForLargerValue[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldReturnCorrectInMemoryStoreTypeOnly[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowForMissingTime[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCaptureInternalTopicNamesIfWrittenInto[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPunctuateOnWallClockTimeDeprecated[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldProcessRecordForTopic[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldForwardRecordsFromSubtopologyToSubtopology[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldNotUpdateStoreForSmallerValue[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCreateStateDirectoryForStatefulTopology[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldNotRequireParameters[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPunctuateIfWallClockTimeAdvances[Eos enabled = true] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCloseProcessor[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldFeedStoreFromGlobalKTable[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCleanUpPersistentStateStoresOnClose[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowForUnknownTopicDeprecated[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowPatternNotValidForTopicNameException[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldEnqueueLaterOutputsAfterEarlierOnes[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldUseSourceSpecificDeserializersDeprecated[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPunctuateIfEvenTimeAdvances[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowNoSuchElementExceptionForUnusedOutputTopicWithDynamicRouting[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldInitProcessor[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowForUnknownTopic[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPunctuateOnStreamsTime[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCaptureGlobalTopicNameIfWrittenInto[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowIfInMemoryBuiltInStoreIsAccessedWithUntypedMethod[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldProcessFromSourcesThatMatchMultiplePattern[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPopulateGlobalStore[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowIfPersistentBuiltInStoreIsAccessedWithUntypedMethod[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldAllowPrePopulatingStatesStoresWithCachingEnabled[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldReturnCorrectPersistentStoreTypeOnly[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldRespectTaskIdling[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldUseSourceSpecificDeserializers[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldReturnAllStores[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldNotCreateStateDirectoryForStatelessTopology[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldReturnAllStoresNames[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPassRecordHeadersIntoSerializersAndDeserializers[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldProcessConsumerRecordList[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldUseSinkSpecificSerializers[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldFlushStoreForFirstInput[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldProcessFromSourceThatMatchPattern[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCaptureSinkTopicNamesIfWrittenInto[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldUpdateStoreForNewKey[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldSendRecordViaCorrectSourceTopicDeprecated[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPunctuateOnWallClockTime[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldSetRecordMetadata[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldNotUpdateStoreForLargerValue[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldReturnCorrectInMemoryStoreTypeOnly[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldThrowForMissingTime[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCaptureInternalTopicNamesIfWrittenInto[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPunctuateOnWallClockTimeDeprecated[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldProcessRecordForTopic[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldForwardRecordsFromSubtopologyToSubtopology[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldNotUpdateStoreForSmallerValue[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldCreateStateDirectoryForStatefulTopology[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldNotRequireParameters[Eos enabled = false] PASSED org.apache.kafka.streams.TopologyTestDriverTest > shouldPunctuateIfWallClockTimeAdvances[Eos enabled = false] PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldCreateConsumerRecordsFromKeyValuePairs PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldNotAllowToCreateTopicWithNullTopicNameWithNullKeyAndDefaultTimestamp PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithDefaultTimestamp PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldNotAllowToCreateTopicWithNullTopicNameWithNullKey PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldCreateNullKeyConsumerRecordWithOtherTopicNameAndTimestampWithTimetamp PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldCreateConsumerRecordWithTimestamp PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldNotAllowToCreateTopicWithNullHeaders PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldNotAllowToCreateTopicWithNullTopicNameWithDefaultTimestamp PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldRequireCustomTopicNameIfNotDefaultFactoryTopicName PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithNullKey PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldCreateConsumerRecord PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldCreateNullKeyConsumerRecord PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldCreateConsumerRecordWithOtherTopicName PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldAdvanceTime PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldNotAllowToCreateTopicWithNullTopicNameWithKeyValuePairs PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithKeyValuePairsAndCustomTimestamps PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithKeyValuePairs PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldCreateConsumerRecordWithOtherTopicNameAndTimestamp PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldNotAllowToCreateTopicWithNullTopicNameWithKeyValuePairsAndCustomTimestamps PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldNotAllowToCreateTopicWithNullTopicName PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldCreateConsumerRecordsFromKeyValuePairsWithCustomTimestampAndIncrementsAndNotAdvanceTime PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldCreateNullKeyConsumerRecordWithTimestampWithTimestamp PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithNullKeyAndDefaultTimestamp PASSED org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldCreateConsumerRecordsFromKeyValuePairsWithTimestampAndIncrements PASSED org.apache.kafka.streams.MockTimeTest > shouldGetNanosAsMillis PASSED org.apache.kafka.streams.MockTimeTest > shouldSetStartTime PASSED org.apache.kafka.streams.MockTimeTest > shouldNotAllowNegativeSleep PASSED org.apache.kafka.streams.MockTimeTest > shouldAdvanceTimeOnSleep PASSED > Task :streams:test-utils:test FAILED Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/6.7/userguide/command_line_interface.html#sec:command_line_warnings 39 actionable tasks: 4 executed, 35 up-to-date