Starting a Gradle Daemon (subsequent builds will be faster) Building project 'core' with Scala version 2.11.11 :clients:compileJava UP-TO-DATE :clients:processResources NO-SOURCE :clients:classes UP-TO-DATE :clients:determineCommitId UP-TO-DATE :clients:createVersionFile :clients:jar UP-TO-DATE :clients:compileTestJava UP-TO-DATE :clients:processTestResources UP-TO-DATE :clients:testClasses UP-TO-DATE :core:compileJava NO-SOURCE :core:compileScala UP-TO-DATE :core:processResources NO-SOURCE :core:classes UP-TO-DATE :core:copyDependantLibs UP-TO-DATE :core:jar UP-TO-DATE :core:compileTestJava NO-SOURCE :core:compileTestScala UP-TO-DATE :core:processTestResources UP-TO-DATE :core:testClasses UP-TO-DATE :connect:api:compileJava UP-TO-DATE :connect:api:processResources NO-SOURCE :connect:api:classes UP-TO-DATE :connect:api:copyDependantLibs UP-TO-DATE :connect:api:jar UP-TO-DATE :connect:json:compileJava UP-TO-DATE :connect:json:processResources NO-SOURCE :connect:json:classes UP-TO-DATE :connect:json:copyDependantLibs UP-TO-DATE :connect:json:jar UP-TO-DATE :streams:compileJava UP-TO-DATE :streams:processResources NO-SOURCE :streams:classes UP-TO-DATE :streams:checkstyleMain UP-TO-DATE :streams:compileTestJava UP-TO-DATE :streams:processTestResources UP-TO-DATE :streams:testClasses UP-TO-DATE :streams:checkstyleTest UP-TO-DATE :streams:findbugsMain UP-TO-DATE :streams:test org.apache.kafka.streams.integration.FanoutIntegrationTest > shouldFanoutTheInput PASSED org.apache.kafka.streams.integration.GlobalKTableIntegrationTest > shouldKStreamGlobalKTableLeftJoin PASSED org.apache.kafka.streams.integration.GlobalKTableIntegrationTest > shouldKStreamGlobalKTableJoin PASSED org.apache.kafka.streams.integration.InternalTopicIntegrationTest > shouldCompactTopicsForStateChangelogs PASSED org.apache.kafka.streams.integration.JoinIntegrationTest > testInnerKTableKTable PASSED org.apache.kafka.streams.integration.JoinIntegrationTest > testLeftKTableKTable PASSED org.apache.kafka.streams.integration.InternalTopicIntegrationTest > shouldUseCompactAndDeleteForWindowStoreChangelogs PASSED org.apache.kafka.streams.integration.JoinIntegrationTest > testLeftKStreamKStream PASSED org.apache.kafka.streams.integration.JoinIntegrationTest > testLeftKStreamKTable PASSED org.apache.kafka.streams.integration.JoinIntegrationTest > testOuterKTableKTable PASSED org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest > shouldReduce PASSED org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest > shouldGroupByKey PASSED org.apache.kafka.streams.integration.JoinIntegrationTest > testInnerKStreamKStream PASSED org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest > shouldReduceWindowed PASSED org.apache.kafka.streams.integration.JoinIntegrationTest > testOuterKStreamKStream PASSED org.apache.kafka.streams.integration.JoinIntegrationTest > testInnerKStreamKTable PASSED org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest > shouldCountClicksPerRegionWithZeroByteCache PASSED org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest > shouldCountClicksPerRegionWithNonZeroByteCache PASSED org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest > shouldReduceSessionWindows PASSED org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest > shouldReduce PASSED org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest > shouldAggregate PASSED org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest > shouldCount PASSED org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest > shouldGroupByKey PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithGlobalAutoOffsetResetLatest PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldThrowExceptionOverlappingPattern PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldThrowExceptionOverlappingTopic PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldOnlyReadRecordsWhereEarliestSpecifiedWithInvalidCommittedOffsets PASSED org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest > shouldCountWithInternalStore PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithDefaultGlobalAutoOffsetResetEarliest PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldThrowStreamsExceptionNoResetSpecified PASSED org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest > shouldReduceWindowed PASSED org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest > shouldCountSessionWindows PASSED org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest > shouldAggregateWindowed PASSED org.apache.kafka.streams.integration.QueryableStateIntegrationTest > shouldBeAbleToQueryMapValuesState PASSED org.apache.kafka.streams.integration.QueryableStateIntegrationTest > shouldNotMakeStoreAvailableUntilAllStoresAvailable PASSED org.apache.kafka.streams.integration.QueryableStateIntegrationTest > queryOnRebalance PASSED org.apache.kafka.streams.integration.KStreamRepartitionJoinTest > shouldCorrectlyRepartitionOnJoinOperationsWithZeroSizedCache PASSED org.apache.kafka.streams.integration.QueryableStateIntegrationTest > concurrentAccesses PASSED org.apache.kafka.streams.integration.QueryableStateIntegrationTest > shouldAllowToQueryAfterThreadDied PASSED org.apache.kafka.streams.integration.QueryableStateIntegrationTest > shouldBeAbleToQueryStateWithZeroSizedCache PASSED org.apache.kafka.streams.integration.KStreamRepartitionJoinTest > shouldCorrectlyRepartitionOnJoinOperationsWithNonZeroSizedCache PASSED org.apache.kafka.streams.integration.QueryableStateIntegrationTest > shouldBeAbleToQueryMapValuesAfterFilterState PASSED org.apache.kafka.streams.integration.QueryableStateIntegrationTest > shouldBeAbleToQueryFilterState PASSED org.apache.kafka.streams.integration.QueryableStateIntegrationTest > shouldBeAbleToQueryStateWithNonZeroSizedCache PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldLeftOuterJoinQueryable PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldInnerLeftJoin PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldOuterOuterJoin PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldInnerOuterJoin PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldLeftInnerJoin PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldInnerInnerJoinQueryable PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldInnerOuterJoinQueryable PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldOuterLeftJoin PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldOuterInnerJoin PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldInnerInnerJoin PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldLeftOuterJoin PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldOuterLeftJoinQueryable PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldLeftLeftJoin PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldOuterInnerJoinQueryable PASSED org.apache.kafka.streams.integration.ResetIntegrationTest > testReprocessingFromScratchAfterResetWithIntermediateUserTopic PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldLeftInnerJoinQueryable PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldInnerLeftJoinQueryable PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldLeftLeftJoinQueryable PASSED org.apache.kafka.streams.integration.ResetIntegrationTest > testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic PASSED org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > shouldOuterOuterJoinQueryable PASSED org.apache.kafka.streams.kstream.internals.AbstractStreamTest > testShouldBeExtensible PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveInvalidStoreNameWithWindowedReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullStoreSupplierOnWindowedAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptNullSessionWindowsWhenAggregatingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullReducerOnReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldReduceSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldAllowNullStoreNameWithWindowedReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptNullStateStoreSupplierNameWhenAggregatingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptInvalidStoreNameWhenReducingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldAllowNullStoreNameOnAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldAllowNullStoreNameOnWindowedAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveInvalidStoreNameOnAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptNullAggregatorWhenAggregatingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptInvalidStoreNameWhenAggregatingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldCountWindowedWithInternalStoreName PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldAggregateSessionWindowsWithInternalStoreName PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptNullSessionMergerWhenAggregatingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullAdderOnWindowedAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveInvalidStoreNameOnReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptNullStateStoreSupplierWhenReducingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldCountSessionWindowsWithInternalStoreName PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptNullReducerWhenReducingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldAcceptNullStoreNameWhenCountingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptNullInitializerWhenAggregatingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullStoreSupplierOnCount PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullInitializerOnWindowedAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptNullSessionWindowsWhenCountingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullReducerWithWindowedReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveInvalidStoreNameOnWindowedAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullAdderOnAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullWindowsWithWindowedReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptInvalidStoreNameWhenCountingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullWindowsOnWindowedAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullStoreSupplierOnWindowedCount PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldAllowNullStoreNameOnReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptNullStateStoreSupplierWhenCountingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldCountWindowed PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldCountSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldAcceptNullStoreNameWhenReducingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldAcceptNullStoreNameWhenAggregatingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldAggregateSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldReduceSessionWindowsWithInternalStoreName PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullInitializerOnAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotHaveNullStoreSupplierOnReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest > shouldNotAcceptNullSessionWindowsReducingSessionWindows PASSED org.apache.kafka.streams.kstream.internals.KStreamBranchTest > testKStreamBranch PASSED org.apache.kafka.streams.kstream.internals.KStreamBranchTest > testTypeVariance PASSED org.apache.kafka.streams.kstream.internals.KStreamFlatMapTest > testFlatMap PASSED org.apache.kafka.streams.kstream.internals.KStreamForeachTest > testForeach PASSED org.apache.kafka.streams.kstream.internals.KStreamForeachTest > testTypeVariance PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testOuterJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testWindowing PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testAsymetricWindowingBefore PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testAsymetricWindowingAfter PASSED org.apache.kafka.streams.kstream.internals.KStreamKTableJoinTest > testJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamMapTest > testMap PASSED org.apache.kafka.streams.kstream.internals.KStreamMapTest > testTypeVariance PASSED org.apache.kafka.streams.kstream.internals.KStreamPeekTest > shouldNotAllowNullAction PASSED org.apache.kafka.streams.kstream.internals.KStreamPeekTest > shouldObserveStreamElements PASSED org.apache.kafka.streams.kstream.internals.KStreamSelectKeyTest > testSelectKey PASSED org.apache.kafka.streams.kstream.internals.KStreamSelectKeyTest > testTypeVariance PASSED org.apache.kafka.streams.kstream.internals.KStreamTransformTest > testTransform PASSED org.apache.kafka.streams.kstream.internals.KStreamWindowAggregateTest > testAggBasic PASSED org.apache.kafka.streams.kstream.internals.KStreamWindowAggregateTest > testJoin PASSED org.apache.kafka.streams.kstream.internals.KTableFilterTest > testSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableFilterTest > testNotSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableFilterTest > testSkipNullOnMaterialization PASSED org.apache.kafka.streams.integration.RegexSourceIntegrationTest > testShouldReadFromRegexAndNamedTopics PASSED org.apache.kafka.streams.kstream.internals.KTableFilterTest > testQueryableSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableFilterTest > testQueryableNotSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableFilterTest > testQueryableSkipNullOnMaterialization PASSED org.apache.kafka.streams.integration.RegexSourceIntegrationTest > testRegexMatchesTopicsAWhenCreated PASSED org.apache.kafka.streams.kstream.internals.KTableFilterTest > testQueryableValueGetter PASSED org.apache.kafka.streams.kstream.internals.KTableFilterTest > testTypeVariance PASSED org.apache.kafka.streams.kstream.internals.KTableFilterTest > testQueryableKTable PASSED org.apache.kafka.streams.kstream.internals.KTableFilterTest > testKTable PASSED org.apache.kafka.streams.kstream.internals.KTableFilterTest > testValueGetter PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullMapperOnMapValues PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullPredicateOnFilter PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullOtherTableOnJoin PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullSelectorOnGroupBy PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullJoinerOnLeftJoin PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > testStateStore PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowEmptyFilePathOnWriteAsText PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullOtherTableOnLeftJoin PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullSelectorOnToStream PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullOtherTableOnOuterJoin PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullJoinerOnOuterJoin PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullStoreSupplierInOuterJoin PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullJoinerJoin PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullTopicOnTo PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldAllowNullStoreInJoin PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > testRepartition PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > testStateStoreLazyEval PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullStoreSupplierInJoin PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullStoreSupplierInLeftJoin PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullActionOnForEach PASSED org.apache.kafka.streams.integration.RegexSourceIntegrationTest > testMultipleConsumersCanReadFromPartitionedTopic PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > testKTable PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullPredicateOnFilterNot PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldAllowNullStoreInThrough PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > testValueGetter PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullFilePathOnWriteAsText PASSED org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldAllowNullTopicInThrough PASSED org.apache.kafka.streams.integration.RegexSourceIntegrationTest > testRegexMatchesTopicsAWhenDeleted PASSED org.apache.kafka.streams.integration.RegexSourceIntegrationTest > testNoMessagesSentExceptionFromOverlappingPatterns PASSED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > testSendingOldValue PASSED org.apache.kafka.streams.integration.RegexSourceIntegrationTest > shouldAddStateStoreToRegexDefinedSource PASSED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > testJoin PASSED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > testNotSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > shouldNotThrowIllegalStateExceptionWhenMultiCacheEvictions PASSED org.apache.kafka.streams.kstream.internals.KTableMapKeysTest > testMapKeysConvertingToStream PASSED org.apache.kafka.streams.kstream.internals.KTableSourceTest > testSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableSourceTest > testNotSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableSourceTest > testKTable PASSED org.apache.kafka.streams.kstream.internals.KTableSourceTest > testValueGetter PASSED org.apache.kafka.streams.kstream.internals.SessionWindowTest > shouldOverlapIfOtherWindowIsWithinThisWindow PASSED org.apache.kafka.streams.kstream.internals.SessionWindowTest > shouldNotOverlapIfOtherWindowIsBeforeThisWindow PASSED org.apache.kafka.streams.kstream.internals.SessionWindowTest > cannotCompareSessionWindowWithDifferentWindowType PASSED org.apache.kafka.streams.kstream.internals.SessionWindowTest > shouldOverlapIfOtherWindowContainsThisWindow PASSED org.apache.kafka.streams.kstream.internals.SessionWindowTest > shouldOverlapIfOtherWindowStartIsWithinThisWindow PASSED org.apache.kafka.streams.kstream.internals.SessionWindowTest > shouldOverlapIfOtherWindowEndIsWithinThisWindow PASSED org.apache.kafka.streams.kstream.internals.SessionWindowTest > shouldNotOverlapIsOtherWindowIsAfterThisWindow PASSED org.apache.kafka.streams.kstream.internals.UnlimitedWindowTest > shouldAlwaysOverlap PASSED org.apache.kafka.streams.kstream.internals.UnlimitedWindowTest > cannotCompareUnlimitedWindowWithDifferentWindowType PASSED org.apache.kafka.streams.kstream.JoinWindowsTest > endTimeShouldNotBeBeforeStart PASSED org.apache.kafka.streams.kstream.JoinWindowsTest > shouldUseWindowSizeForMaintainDurationWhenSizeLargerThanDefaultMaintainMs PASSED org.apache.kafka.streams.kstream.JoinWindowsTest > shouldHaveSaneEqualsAndHashCode PASSED org.apache.kafka.streams.kstream.JoinWindowsTest > validWindows PASSED org.apache.kafka.streams.kstream.JoinWindowsTest > startTimeShouldNotBeAfterEnd PASSED org.apache.kafka.streams.kstream.JoinWindowsTest > untilShouldSetMaintainDuration PASSED org.apache.kafka.streams.kstream.JoinWindowsTest > retentionTimeMustNoBeSmallerThanWindowSize PASSED org.apache.kafka.streams.kstream.JoinWindowsTest > timeDifferenceMustNotBeNegative PASSED org.apache.kafka.streams.kstream.SessionWindowsTest > retentionTimeShouldBeGapIfGapIsLargerThanDefaultRetentionTime PASSED org.apache.kafka.streams.kstream.SessionWindowsTest > shouldSetWindowGap PASSED org.apache.kafka.streams.kstream.SessionWindowsTest > retentionTimeMustNotBeNegative PASSED org.apache.kafka.streams.kstream.SessionWindowsTest > windowSizeMustNotBeZero PASSED org.apache.kafka.streams.kstream.SessionWindowsTest > windowSizeMustNotBeNegative PASSED org.apache.kafka.streams.kstream.SessionWindowsTest > shouldSetWindowRetentionTime PASSED org.apache.kafka.streams.kstream.UnlimitedWindowsTest > startTimeMustNotBeNegative PASSED org.apache.kafka.streams.kstream.UnlimitedWindowsTest > shouldThrowOnUntil PASSED org.apache.kafka.streams.kstream.UnlimitedWindowsTest > shouldIncludeRecordsThatHappenedOnWindowStart PASSED org.apache.kafka.streams.kstream.UnlimitedWindowsTest > shouldSetWindowStartTime PASSED org.apache.kafka.streams.kstream.UnlimitedWindowsTest > shouldIncludeRecordsThatHappenedAfterWindowStart PASSED org.apache.kafka.streams.kstream.UnlimitedWindowsTest > shouldExcludeRecordsThatHappenedBeforeWindowStart PASSED org.apache.kafka.streams.kstream.WindowsTest > retentionTimeMustNotBeNegative PASSED org.apache.kafka.streams.kstream.WindowsTest > numberOfSegmentsMustBeAtLeastTwo PASSED org.apache.kafka.streams.kstream.WindowsTest > shouldSetWindowRetentionTime PASSED org.apache.kafka.streams.kstream.WindowsTest > shouldSetNumberOfSegments PASSED org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenAuthorizationException PASSED org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowProcessorStateExceptionOnInitializeOffsetsWhenKafkaException PASSED org.apache.kafka.streams.processor.internals.AbstractTaskTest > shouldThrowWakeupExceptionOnInitializeOffsetsWhenWakeupException PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowLockExceptionIfCantGetLock PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowStreamsExceptionIfNoPartitionsFoundForStore PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldNotCloseStoresIfCloseAlreadyCalled PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowProcessorStateStoreExceptionIfStoreFlushFailed PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowStreamsExceptionIfFailedToReadCheckpointedOffsets PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldWriteCheckpointsOnClose PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowProcessorStateStoreExceptionIfStoreCloseFailed PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldRestoreRecordsUpToHighwatermark PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldNotDeleteCheckpointFileAfterLoaded PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldInitializeStateStores PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldSkipNullKeysWhenRestoring PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldReturnInitializedStoreNames PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldCheckpointRestoredOffsetsToFile PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldUnlockGlobalStateDirectoryOnClose PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldCheckpointOffsets PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldAttemptToCloseAllStoresEvenWhenSomeException PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowIllegalArgumentExceptionIfCallbackIsNull PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldReadCheckpointOffsets PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldCloseStateStores PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowIllegalArgumentIfTryingToRegisterStoreThatIsNotGlobal PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldFlushStateStores PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldLockGlobalStateDirectory PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldRestoreRecordsFromCheckpointToHighwatermark PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowLockExceptionIfIOExceptionCaughtWhenTryingToLockStateDir PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldThrowIllegalArgumentExceptionIfAttemptingToRegisterStoreTwice PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldReleaseLockIfExceptionWhenLoadingCheckpoints PASSED org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest > shouldNotRemoveOffsetsOfUnUpdatedTablesDuringCheckpoint PASSED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldStayDeadAfterTwoCloses PASSED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldTransitiontoRunningOnStart PASSED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldCloseStateStoresOnClose PASSED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldBeRunningAfterSuccessfulStart PASSED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldTransitionToDeadOnClose PASSED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldStopRunningWhenClosedByUser PASSED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldThrowStreamsExceptionOnStartupIfThereIsAStreamsException PASSED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldThrowStreamsExceptionOnStartupIfExceptionOccurred PASSED org.apache.kafka.streams.processor.internals.InternalTopicManagerTest > shouldCreateRequiredTopics PASSED org.apache.kafka.streams.processor.internals.InternalTopicManagerTest > shouldNotThrowExceptionIfExistsWithDifferentReplication PASSED org.apache.kafka.streams.processor.internals.InternalTopicManagerTest > shouldReturnCorrectPartitionCounts PASSED org.apache.kafka.streams.processor.internals.InternalTopicManagerTest > shouldNotThrowExceptionForEmptyTopicMap PASSED org.apache.kafka.streams.processor.internals.InternalTopicManagerTest > shouldNotCreateTopicIfExistsWithDifferentPartitions PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > testTimeTracking PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testFlushAndClose PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > shouldThrowLockExceptionIfFailedToLockStateDirectory PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testRegisterNonPersistentStore PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > shouldRegisterStoreWithoutLoggingEnabledAndNotBackedByATopic PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testGetStore PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > shouldThrowProcessorStateExceptionOnCloseIfStoreThrowsAnException PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > shouldWriteCheckpointForStandbyReplica PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > shouldNotWriteCheckpointForNonPersistent PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > shouldNotWriteCheckpointForStoresWithoutChangelogTopic PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > shouldDeleteCheckpointFileOnCreationIfEosEnabled PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testChangeLogOffsets PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > shouldWriteCheckpointForPersistentLogEnabledStore PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > testRegisterPersistentStore PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > shouldThrowIllegalArgumentExceptionOnRegisterWhenStoreHasAlreadyBeenRegistered PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > shouldNotChangeOffsetsIfAckedOffsetsIsNull PASSED org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest > shouldThrowIllegalArgumentExceptionIfStoreNameIsSameAsCheckpointFileName PASSED org.apache.kafka.streams.processor.internals.PunctuationQueueTest > testPunctuationInterval PASSED org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldThrowStreamsExceptionOnFlushIfASendFailed PASSED org.apache.kafka.streams.processor.internals.RecordCollectorTest > testSpecificPartition PASSED org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldThrowStreamsExceptionOnSubsequentCallIfASendFails PASSED org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldThrowStreamsExceptionAfterMaxAttempts PASSED org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldRetryWhenTimeoutExceptionOccursOnSend PASSED org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldThrowIfTopicIsUnknown PASSED org.apache.kafka.streams.processor.internals.RecordCollectorTest > shouldThrowStreamsExceptionOnCloseIfASendFailed PASSED org.apache.kafka.streams.processor.internals.RecordCollectorTest > testStreamPartitioner PASSED org.apache.kafka.streams.processor.internals.SinkNodeTest > shouldHandleNullValuesWhenThrowingStreamsExceptionOnKeyValueTypeSerializerMismatch PASSED org.apache.kafka.streams.processor.internals.SinkNodeTest > shouldThrowStreamsExceptionOnInputRecordWithInvalidTimestamp PASSED org.apache.kafka.streams.processor.internals.SinkNodeTest > shouldHandleNullKeysWhenThrowingStreamsExceptionOnKeyValueTypeSerializerMismatch PASSED org.apache.kafka.streams.processor.internals.SinkNodeTest > shouldThrowStreamsExceptionOnKeyValueTypeSerializerMismatch PASSED org.apache.kafka.streams.processor.internals.SourceNodeTest > shouldProvideTopicHeadersAndDataToKeyDeserializer PASSED org.apache.kafka.streams.processor.internals.SourceNodeTest > shouldProvideTopicHeadersAndDataToValueDeserializer PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldNotFlushOffsetsWhenFlushIntervalHasNotLapsed PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldNotFlushWhenFlushIntervalIsZero PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldUpdateStateWithReceivedRecordsForPartition PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldSeekToInitialOffsets PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldCloseConsumer PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldFlushStoreWhenFlushIntervalHasLapsed PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldUpdateStateWithReceivedRecordsForAllTopicPartition PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldAssignPartitionsToConsumer PASSED org.apache.kafka.streams.processor.internals.StateConsumerTest > shouldCloseStateMaintainer PASSED org.apache.kafka.streams.processor.internals.StateRestorerTest > shouldSetRestoredOffsetToMinOfLimitAndOffset PASSED org.apache.kafka.streams.processor.internals.StateRestorerTest > shouldBeCompletedIfRecordOffsetGreaterThanEndOffset PASSED org.apache.kafka.streams.processor.internals.StateRestorerTest > shouldCallRestoreOnRestoreCallback PASSED org.apache.kafka.streams.processor.internals.StateRestorerTest > shouldReturnCorrectNumRestoredRecords PASSED org.apache.kafka.streams.processor.internals.StateRestorerTest > shouldBeCompletedIfEndOffsetAndRecordOffsetAreZero PASSED org.apache.kafka.streams.processor.internals.StateRestorerTest > shouldSetStartingOffsetToMinOfLimitAndOffset PASSED org.apache.kafka.streams.processor.internals.StateRestorerTest > shouldBeCompletedIfRecordOffsetGreaterThanOffsetLimit PASSED org.apache.kafka.streams.processor.internals.StateRestorerTest > shouldBeCompletedIfOffsetAndOffsetLimitAreZero PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldUpdatePartitionHostInfoMapOnAssignment PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldThrowExceptionIfApplicationServerConfigIsNotHostPortPair PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldMapUserEndPointToTopicPartitions PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldAddUserDefinedEndPointToSubscription PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithStandbyReplicas PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldNotLoopInfinitelyOnMissingMetadataAndShouldNotCreateRelatedTasks PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithNewTasks PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldExposeHostStateToTopicPartitionsOnAssignment PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithStates PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldThrowKafkaExceptionIfStreamThreadConfigIsNotStreamThreadInstance PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldThrowExceptionIfApplicationServerConfigPortIsNotAnInteger PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignEmptyMetadata PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldReturnEmptyClusterMetadataIfItHasntBeenBuilt PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithPartialTopology PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignBasic PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testOnAssignment PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithInternalTopicThatsSourceIsAnotherInternalTopic PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testSubscription PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldUpdateClusterMetadataOnAssignment PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldSetClusterMetadataOnAssignment PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > testAssignWithInternalTopics PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldThrowKafkaExceptionIfStreamThreadNotConfigured PASSED org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest > shouldNotAddStandbyTaskPartitionsToPartitionsForHost PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveUnfulfilledQuotaWhenActiveTaskSizeLessThanCapacityTimesTasksPerThread PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfActiveTaskAssigned PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldUseMultiplesOfCapacityToDetermineClientWithMoreAvailableCapacity PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveNotReachedCapacityWhenAssignedTasksLessThanCapacity PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousActiveTasksToPreviousAssignedAndPreviousActive PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfThisClientStateIsZero PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveAssignedTaskIfTaskNotAssigned PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityTheSameButFewerAssignedTasks PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddStandbyTasksToBothStandbyAndActive PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousStandbyTasksToPreviousAssigned PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfOtherClientStateIsZero PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityIsTheSameButAssignedTasksIsLess PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddActiveTasksToBothAssignedAndActive PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfStandbyTaskAssigned PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveUnfulfilledQuotaWhenActiveTaskSizeGreaterEqualThanCapacityTimesTasksPerThread PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityHigherAndSameAssignedTaskCount PASSED org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveReachedCapacityWhenAssignedTasksGreaterThanOrEqualToCapacity PASSED org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > testEncodeDecode PASSED org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeDecodeWithUserEndPoint PASSED org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldBeBackwardCompatible PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseTaskAsZombieAndRemoveFromActiveTasksIfProducerGotFencedAtBeginTransactionWhenTaskIsResumed PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotNullPointerWhenStandbyTasksAssignedAndNoStateStoresForTopology PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldInjectSharedProducerForAllTasksUsingClientSupplierOnCreateIfEosDisabled PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseActiveTasksThatAreAssignedToThisStreamThreadButAssignmentHasChangedBeforeCreatingNewTasks PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldInjectProducerPerTaskUsingClientSupplierOnCreateIfEosEnable PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testPartitionAssignmentChangeForMultipleGroups PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldReleaseStateDirLockIfFailureOnStandbyTaskSuspend PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotViolateAtLeastOnceWhenExceptionOccursDuringFlushStateWhileSuspendingState PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldInitializeRestoreConsumerWithOffsetsFromStandbyTasks PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldReleaseStateDirLockIfFailureOnStandbyTaskCloseForUnassignedSuspendedStandbyTask PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testHandingOverTaskFromOneToAnotherThread PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testMaybeCommit PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testStateChangeStartClose PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseAllTaskProducersOnCloseIfEosEnabled PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotViolateAtLeastOnceWhenAnExceptionOccursOnTaskCloseDuringShutdown PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testMaybeClean PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testMetrics PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseSuspendedTasksThatAreNoLongerAssignedToThisStreamThreadBeforeCreatingNewTasks PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > testPartitionAssignmentChangeForSingleGroup PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotCloseSuspendedTaskswice PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldReleaseStateDirLockIfFailureOnTaskSuspend PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotViolateAtLeastOnceWhenExceptionOccursDuringTaskSuspension PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldNotViolateAtLeastOnceWhenAnExceptionOccursOnTaskFlushDuringShutdown PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldAlwaysUpdateWithLatestTopicsFromStreamPartitionAssignor PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseTaskAsZombieAndRemoveFromActiveTasksIfProducerWasFencedWhileProcessing PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldCloseThreadProducerOnCloseIfEosDisabled PASSED org.apache.kafka.streams.processor.internals.StreamThreadTest > shouldReleaseStateDirLockIfFailureOnTaskCloseForSuspendedTask PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstancesForStoreName PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowWhenSerializerIsNull PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetAllStreamInstances PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetAnyHostForGlobalStoreByKeyAndPartitionerIfMyHostUnknown PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKey PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldHaveGlobalStoreInAllMetadata PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetAllStreamsInstancesWithNoStores PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetAnyHostForGlobalStoreByKeyIfMyHostUnknown PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetMyMetadataForGlobalStoreWithKey PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowWhenKeyIsNull PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyWithMergedStreams PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldNotThrowNPEWhenOnChangeNotCalled PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNull PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNotAvailableWhenClusterIsEmpty PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetMyMetadataForGlobalStoreWithKeyAndPartitioner PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnEmptyCollectionOnGetAllInstancesWithStoreWhenStoreDoesntExist PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldReturnNullOnGetWithKeyWhenStoreDoesntExist PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStreamPartitionerIsNull PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldGetInstanceWithKeyAndCustomPartitioner PASSED org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > shouldThrowIfStoreNameIsNullOnGetAllInstancesWithStore PASSED org.apache.kafka.streams.processor.DefaultPartitionGrouperTest > shouldComputeGroupingForSingleGroupWithMultipleTopics PASSED org.apache.kafka.streams.processor.DefaultPartitionGrouperTest > shouldNotCreateAnyTasksBecauseOneTopicHasUnknownPartitions PASSED org.apache.kafka.streams.processor.DefaultPartitionGrouperTest > shouldComputeGroupingForTwoGroups PASSED org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestampTest > logAndSkipOnInvalidTimestamp PASSED org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestampTest > extractMetadataTimestamp PASSED org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > usePreviousTimeOnInvalidTimestamp PASSED org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > shouldThrowStreamsException PASSED org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > extractMetadataTimestamp PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldCleanupNamedCacheOnClose PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldThrowIfNoPeekNextKey PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldNotLoopForEverWhenEvictingAndCurrentCacheIsEmpty PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldDelete PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldEvictImmediatelyIfCacheSizeIsZero PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldPutAll PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldSkipEntriesWhereValueHasBeenEvictedFromCache PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldGetSameKeyAsPeekNext PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > basicPutGet PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldPeekAndIterateOverRange PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldNotClashWithOverlappingNames PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > cacheOverheadsLargeValues PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > evict PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldNotBlowUpOnNonExistentKeyWhenDeleting PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldNotFlushAfterDelete PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldNotForwardCleanEntryOnEviction PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldNotBlowUpOnNonExistentNamespaceWhenDeleting PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRunWithEosEnabled PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > cacheOverheadsSmallValues PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldPutIfAbsent PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldReturnFalseIfNoNextKey PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldFlushDirtyEntriesForNamespace PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldPeekNextKey PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldReturnNullIfKeyIsNull PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldNotFlushCleanEntriesForNamespace PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldEvictAfterPutIfAbsent PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldEvictAfterPutAll PASSED org.apache.kafka.streams.state.internals.ThreadCacheTest > shouldEvictImmediatelyIfCacheSizeIsVerySmall PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldFetchExactKeys PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldRemove PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldFindValuesWithinMergingSessionWindowRange PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldThrowNullPointerExceptionOnRemoveNullKey PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldThrowNullPointerExceptionOnFetchNullFromKey PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldThrowNullPointerExceptionOnFindSessionsNullFromKey PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldFetchAllSessionsWithSameRecordKey PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldThrowNullPointerExceptionOnFetchNullToKey PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldThrowNullPointerExceptionOnPutNullKey PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldFindSessionsToMerge PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldThrowNullPointerExceptionOnFindSessionsNullToKey PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldThrowNullPointerExceptionOnFindSessionsNullKey PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldPutAndFindSessionsInRange PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldThrowNullPointerExceptionOnFetchNullKey PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldPutFetchFromCache PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldPutFetchRangeFromCache PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldFetchAndIterateOverKeyRange PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldNotThrowNullPointerExceptionOnPutNullValue PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldIterateCacheAndStore PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldClearNamespaceCacheOnClose PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldThrowIfTryingToFetchRangeFromClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldFetchAndIterateOverExactKeys PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldTakeValueFromCacheIfSameTimestampFlushedToRocks PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldForwardDirtyItemsWhenFlushCalled PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldIterateAcrossWindows PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldThrowNullPointerExceptionOnPutNullKey PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldThrowIfTryingToFetchFromClosedCachingStore PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToCommitToMultiplePartitions PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldFlushEvictedItemsIntoUnderlyingStore PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldIterateCacheAndStoreKeyRange PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldThrowNullPointerExceptionOnRangeNullToKey PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldThrowNullPointerExceptionOnRangeNullFromKey PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldForwardOldValuesWhenEnabled PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldThrowIfTryingToWriteToClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldThrowNullPointerExceptionOnFetchNullKey PASSED org.apache.kafka.streams.state.internals.CachingWindowStoreTest > shouldForwardDirtyItemToListenerWhenEvicted PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldWriteAllKeyValueToInnerStoreOnPutAll PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldLogChangeOnPut PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldWriteToChangelogOnPutIfAbsentWhenNoPreviousValue PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldPutNullOnDelete PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldWriteToInnerOnPutIfAbsentNoPreviousValue PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldQueryRange PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldWriteKeyValueBytesToInnerStoreOnPut PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldReturnCurrentValueOnPutIfAbsent PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldLogChangesOnPutAll PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldNotWriteToChangeLogOnPutIfAbsentWhenValueForKeyExists PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldReturnNullOnPutIfAbsentWhenNoPreviousValue PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldLogKeyNullOnDelete PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldReturnNullOnDeleteIfNoOldValue PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldReturnNullOnGetWhenDoesntExist PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldReturnOldValueOnDelete PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldReturnInnerStoreName PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldNotWriteToInnerOnPutIfAbsentWhenValueForKeyExists PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldReturnValueOnGetWhenExists PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueStoreTest > shouldReturnAllKeyValues PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldReturnValueIfExists PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldNotGetValuesFromOtherStores PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldThrowUnsupportedOperationExceptionWhileRange PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldGetApproximateEntriesAcrossAllStores PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldReturnLongMaxValueOnOverflow PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldReturnNullIfKeyDoesntExist PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldThrowInvalidStoreExceptionOnApproximateNumEntriesDuringRebalance PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldThrowNoSuchElementExceptionWhilePeekNext PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldThrowInvalidStoreExceptionDuringRebalance PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldThrowInvalidStoreExceptionOnAllDuringRebalance PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldSupportRange PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldThrowNoSuchElementExceptionWhileNext PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldFindValueForKeyWhenMultiStores PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldThrowInvalidStoreExceptionOnRangeDuringRebalance PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldThrowNullPointerExceptionOnRangeNullToKey PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldThrowNullPointerExceptionOnGetNullKey PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldThrowUnsupportedOperationExceptionWhileRemove PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldThrowNullPointerExceptionOnRangeNullFromKey PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldSupportRangeAcrossMultipleKVStores PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > shouldSupportAllAcrossMultipleStores PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest > emptyIteratorPeekNextKeyShouldThrowNoSuchElementException PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest > emptyIteratorAlwaysReturnsFalse PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest > shouldNotGetValuesFromOtherStores PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest > shouldReturnEmptyIteratorIfNoData PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest > shouldThrowInvalidStateStoreExceptionIfFetchThrows PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest > emptyIteratorNextShouldThrowNoSuchElementException PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest > shouldFindValueForKeyWhenMultiStores PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest > shouldThrowInvalidStateStoreExceptionOnRebalance PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest > shouldFetchValuesFromWindowStore PASSED org.apache.kafka.streams.state.internals.FilteredCacheIteratorTest > shouldNotHaveNextIfHasNextConditionNotMet PASSED org.apache.kafka.streams.state.internals.FilteredCacheIteratorTest > shouldThrowUnsupportedOperationExeceptionOnRemove PASSED org.apache.kafka.streams.state.internals.FilteredCacheIteratorTest > shouldPeekNext PASSED org.apache.kafka.streams.state.internals.FilteredCacheIteratorTest > shouldAllowEntryMatchingHasNextCondition PASSED org.apache.kafka.streams.state.internals.FilteredCacheIteratorTest > shouldPeekNextKey PASSED org.apache.kafka.streams.state.internals.FilteredCacheIteratorTest > shouldFilterEntriesNotMatchingHasNextCondition PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > shouldPutAll PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > shouldNotThrowNullPointerExceptionOnPutIfAbsentNullValue PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > shouldThrowNullPointerExceptionOnPutAllNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > testSize PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > shouldNotThrowNullPointerExceptionOnPutNullValue PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > shouldThrowNullPointerExceptionOnPutIfAbsentNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > testPutIfAbsent PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > testRestoreWithDefaultSerdes PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > shouldThrowNullPointerExceptionOnPutNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > testRestore PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > shouldThrowNullPointerExceptionOnRangeNullToKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > shouldNotThrowNullPointerExceptionOnPutAllNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > testPutGetRange PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > shouldThrowNullPointerExceptionOnGetNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > shouldThrowNullPointerExceptionOnRangeNullFromKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > shouldThrowNullPointerExceptionOnDeleteNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest > testPutGetRangeWithDefaultSerdes PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldPutAllKeyValuePairs PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testRestoreEvict PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testEvict PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldUpdateValuesForExistingKeysOnPutAll PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldNotThrowNullPointerExceptionOnPutIfAbsentNullValue PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldThrowNullPointerExceptionOnPutAllNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testSize PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldNotThrowNullPointerExceptionOnPutNullValue PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldThrowNullPointerExceptionOnPutIfAbsentNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testPutIfAbsent PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testRestoreWithDefaultSerdes PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldThrowNullPointerExceptionOnPutNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testRestore PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldThrowNullPointerExceptionOnRangeNullToKey PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldNotThrowNullPointerExceptionOnPutAllNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testPutGetRange PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldThrowNullPointerExceptionOnGetNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldThrowNullPointerExceptionOnRangeNullFromKey PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > shouldThrowNullPointerExceptionOnDeleteNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest > testPutGetRangeWithDefaultSerdes PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedSessionStoreIteratorTest > shouldHaveNextFromCache PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedSessionStoreIteratorTest > shouldHaveNextFromStore PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedSessionStoreIteratorTest > shouldPeekNextKeyFromCache PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedSessionStoreIteratorTest > shouldPeekNextKeyFromStore PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedSessionStoreIteratorTest > shouldIterateBothStoreAndCache PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedSessionStoreIteratorTest > shouldGetNextFromCache PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedSessionStoreIteratorTest > shouldGetNextFromStore PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest > shouldHaveNextFromCache PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest > shouldHaveNextFromStore PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest > shouldPeekNextKeyFromCache PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest > shouldPeekNextKeyFromStore PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest > shouldIterateBothStoreAndCache PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest > shouldGetNextFromCache PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest > shouldGetNextFromStore PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldNotThrowNullPointerWhenCacheIsEmptyAndEvictionCalled PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldEvictEldestEntry PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldBeReentrantAndNotBreakLRU PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldDeleteAndUpdateSize PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldPutAll PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldPutGet PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldNotThrowIllegalArgumentAfterEvictingDirtyRecordAndThenPuttingNewRecordWithSameKey PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldGetIteratorOverAllKeys PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldKeepTrackOfMostRecentlyAndLeastRecentlyUsed PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldRemoveDeletedValuesOnFlush PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > testMetrics PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldGetRangeIteratorOverKeys PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldFlushDirtEntriesOnEviction PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldPutIfAbsent PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldThrowIllegalStateExceptionWhenTryingToOverwriteDirtyEntryWithCleanEntry PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldReturnNullIfKeyIsNull PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldOverwriteAll PASSED org.apache.kafka.streams.state.internals.NamedCacheTest > shouldKeepTrackOfSize PASSED org.apache.kafka.streams.state.internals.QueryableStoreProviderTest > shouldThrowExceptionIfWindowStoreDoesntExist PASSED org.apache.kafka.streams.state.internals.QueryableStoreProviderTest > shouldThrowExceptionWhenLookingForWindowStoreWithDifferentType PASSED org.apache.kafka.streams.state.internals.QueryableStoreProviderTest > shouldFindGlobalStores PASSED org.apache.kafka.streams.state.internals.QueryableStoreProviderTest > shouldReturnKVStoreWhenItExists PASSED org.apache.kafka.streams.state.internals.QueryableStoreProviderTest > shouldThrowExceptionWhenLookingForKVStoreWithDifferentType PASSED org.apache.kafka.streams.state.internals.QueryableStoreProviderTest > shouldReturnWindowStoreWhenItExists PASSED org.apache.kafka.streams.state.internals.QueryableStoreProviderTest > shouldThrowExceptionIfKVStoreDoesntExist PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldUseCustomRocksDbConfigSetter PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldPerformAllQueriesWithCachingDisabled PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldPerformRangeQueriesWithCachingDisabled PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldCloseOpenIteratorsWhenStoreClosedAndThrowInvalidStateStoreOnHasNextAndNext PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldNotThrowNullPointerExceptionOnPutIfAbsentNullValue PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutAllNullKey PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > testSize PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldNotThrowNullPointerExceptionOnPutNullValue PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutIfAbsentNullKey PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > testPutIfAbsent PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > testRestoreWithDefaultSerdes PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutNullKey PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > testRestore PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldThrowNullPointerExceptionOnRangeNullToKey PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldNotThrowNullPointerExceptionOnPutAllNullKey PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > testPutGetRange PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldThrowNullPointerExceptionOnGetNullKey PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldThrowNullPointerExceptionOnRangeNullFromKey PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > shouldThrowNullPointerExceptionOnDeleteNullKey PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest > testPutGetRangeWithDefaultSerdes PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > shouldHaveMeteredStoreWhenNotLoggedOrCached PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > shouldReturnRocksDbStoreWhenCachingDisabled PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > shouldCreateLoggingEnabledStoreWhenStoreLogged PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > shouldReturnCachedSessionStoreWhenCachingEnabled PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > shouldNotBeLoggingEnabledStoreWhenLoggingNotEnabled PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > shouldHaveMeteredStoreWhenCached PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > shouldHaveMeteredStoreWhenLogged PASSED org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > shouldReturnRocksDbStoreWhenCachingAndLoggingDisabled PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testCachingEnabled PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldNotViolateEosIfOneTaskFails PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testPutAndFetch PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > shouldNotThrowNullPointerExceptionOnPutNullValue PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > shouldCloseOpenIteratorsWhenStoreIsClosedAndThrowInvalidStateStoreExceptionOnHasNextAndNext PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testPutAndFetchBefore PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testFetchRange PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > shouldFetchAndIterateOverExactKeys PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testInitialLoading PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > shouldOnlyIterateOpenSegments PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > shouldThrowNullPointerExceptionOnPutNullKey PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToPerformMultipleTransactions PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testRestore PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > shouldThrowNullPointerExceptionOnRangeNullToKey PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testRolling PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testSegmentMaintenance PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > shouldThrowNullPointerExceptionOnGetNullKey PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testPutSameKeyTimestamp PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > shouldThrowNullPointerExceptionOnRangeNullFromKey PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > testPutAndFetchAfter PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest > shouldFetchAndIterateOverExactBinaryKeys PASSED org.apache.kafka.streams.state.internals.SegmentedCacheFunctionTest > cacheKey PASSED org.apache.kafka.streams.state.internals.SegmentedCacheFunctionTest > key PASSED org.apache.kafka.streams.state.internals.SegmentedCacheFunctionTest > testRoundTripping PASSED org.apache.kafka.streams.state.internals.SegmentedCacheFunctionTest > compareSegmentedKeys PASSED org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest > shouldReturnNextValueWhenItExists PASSED org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest > shouldThrowNoSuchElementOnNextWhenIteratorExhausted PASSED org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest > shouldReturnTrueOnHasNextWhenMoreResults PASSED org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest > shouldThrowUnsupportedOperationOnRemove PASSED org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest > shouldPeekNextKey PASSED org.apache.kafka.streams.state.internals.SerializedKeyValueIteratorTest > shouldReturnFalseOnHasNextWhenNoMoreResults PASSED org.apache.kafka.streams.state.internals.StoreChangeLoggerTest > testAddRemove PASSED org.apache.kafka.streams.state.internals.WindowKeySchemaTest > testUpperBoundWithLargeTimestamps PASSED org.apache.kafka.streams.state.internals.WindowKeySchemaTest > testUpperBoundWithZeroTimestamp PASSED org.apache.kafka.streams.state.internals.WindowKeySchemaTest > testLowerBoundMatchesTrailingZeros PASSED org.apache.kafka.streams.state.internals.WindowKeySchemaTest > testUpperBoundWithKeyBytesLargerThanFirstTimestampByte PASSED org.apache.kafka.streams.state.internals.WindowKeySchemaTest > testLowerBoundWithMonZeroTimestamp PASSED org.apache.kafka.streams.state.internals.WindowKeySchemaTest > testUpperBoundWithKeyBytesLargerAndSmallerThanFirstTimestampByte PASSED org.apache.kafka.streams.state.internals.WindowKeySchemaTest > testLowerBoundWithZeroTimestamp PASSED org.apache.kafka.streams.state.internals.WrappingStoreProviderTest > shouldThrowInvalidStoreExceptionIfNoStoreOfTypeFound PASSED org.apache.kafka.streams.state.internals.WrappingStoreProviderTest > shouldFindWindowStores PASSED org.apache.kafka.streams.state.internals.WrappingStoreProviderTest > shouldFindKeyValueStores PASSED org.apache.kafka.streams.state.StoresTest > shouldThrowIllegalArgumentExceptionWhenTryingToConstructWindowStoreWithLessThanTwoSegments PASSED org.apache.kafka.streams.state.StoresTest > shouldCreateInMemoryStoreSupplierWithLoggedConfig PASSED org.apache.kafka.streams.state.StoresTest > shouldCreatePersistenStoreSupplierNotLogged PASSED org.apache.kafka.streams.state.StoresTest > shouldCreatePersistenStoreSupplierWithLoggedConfig PASSED org.apache.kafka.streams.state.StoresTest > shouldCreateInMemoryStoreSupplierNotLogged PASSED org.apache.kafka.streams.KeyValueTest > shouldHaveSaneEqualsAndHashCode PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToCommitMultiplePartitionOffsets PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRunWithTwoSubtopologies PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldNotViolateEosIfOneTaskGetsFencedUsingIsolatedAppInstances PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldNotViolateEosIfOneTaskFailsWithState PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRunWithTwoSubtopologiesAndMultiplePartitions PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRestartAfterClose PASSED org.apache.kafka.streams.kstream.internals.GlobalKTableJoinsTest > shouldInnerJoinWithStream PASSED org.apache.kafka.streams.kstream.internals.GlobalKTableJoinsTest > shouldLeftJoinWithStream PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldNotAllowNullSubtractorOnAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldNotAllowNullInitializerOnAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldAllowNullStoreNameOnCount PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldAllowNullStoreNameOnAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldNotAllowInvalidStoreNameOnAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldNotAllowNullAdderOnReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldNotAllowNullStoreSupplierOnReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldAllowNullStoreNameOnReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldNotAllowNullAdderOnAggregate PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldNotAllowNullSubtractorOnReduce PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldReduceWithInternalStoreName PASSED org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest > shouldNotAllowInvalidStoreNameOnReduce PASSED org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testFilterNot PASSED org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testTypeVariance PASSED org.apache.kafka.streams.kstream.internals.KStreamFilterTest > testFilter PASSED org.apache.kafka.streams.kstream.internals.KStreamFlatMapValuesTest > testFlatMapValues PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullProcessSupplier PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullMapperOnMapValues PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullPredicateOnFilter PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullTopicOnThrough PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > testToWithNullValueSerdeDoesntNPE PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullSelectorOnGroupBy PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullTransformSupplierOnTransformValues PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullTableOnTableJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > testNumProcesses PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowEmptyFilePathOnWriteAsText PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullMapperOnFlatMapValues PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullMapperOnSelectKey PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullTopicOnTo PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullTransformSupplierOnTransform PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldUseRecordMetadataTimestampExtractorWhenInternalRepartitioningTopicCreated PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullMapperOnMap PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullJoinWindowsOnJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullJoinerOnLeftJoinWithGlobalTable PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullJoinerOnJoinWithGlobalTable PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullValueJoinerOnJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullTableOnJoinWithGlobalTable PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullOtherStreamOnJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullTableOnJLeftJoinWithGlobalTable PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullMapperOnFlatMap PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldCantHaveNullPredicate PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullMapperOnJoinWithGlobalTable PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullActionOnForEach PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullValueMapperOnTableJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullMapperOnLeftJoinWithGlobalTable PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldUseRecordMetadataTimestampExtractorWithThrough PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullPredicateOnFilterNot PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldHaveAtLeastOnPredicateWhenBranching PASSED org.apache.kafka.streams.kstream.internals.KStreamImplTest > shouldNotAllowNullFilePathOnWriteAsText PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamLeftJoinTest > testLeftJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamLeftJoinTest > testWindowing PASSED org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > testJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamMapValuesTest > testFlatMapValues PASSED org.apache.kafka.streams.kstream.internals.KStreamPrintTest > testPrintKeyValueWithName PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldRemoveMergedSessionsFromStateStore PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldMergeSessions PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldHandleMultipleSessionsAndMerging PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldImmediatelyForwardNewSessionWhenNonCachedStore PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldGetAggregatedValuesFromValueGetter PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldImmediatelyForwardRemovedSessionsWhenMerging PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldUpdateSessionIfTheSameTime PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldHaveMultipleSessionsForSameIdWhenTimestampApartBySessionGap PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldCreateSingleSessionWhenWithinGap PASSED org.apache.kafka.streams.kstream.internals.KStreamTransformValuesTest > shouldNotAllowValueTransformerToCallInternalProcessorContextMethods PASSED org.apache.kafka.streams.kstream.internals.KStreamTransformValuesTest > testTransform PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testAggBasic PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > shouldForwardToCorrectProcessorNodeWhenMultiCacheEvictions PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testCount PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testCountWithInternalStore PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testAggCoalesced PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testAggRepartition PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testRemoveOldBeforeAddNew PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testCountCoalesced PASSED org.apache.kafka.streams.kstream.internals.KTableForeachTest > testForeach PASSED org.apache.kafka.streams.kstream.internals.KTableForeachTest > testTypeVariance PASSED org.apache.kafka.streams.kstream.internals.KTableKTableJoinTest > testJoin PASSED org.apache.kafka.streams.kstream.internals.KTableKTableJoinTest > testNotSendingOldValues PASSED org.apache.kafka.streams.kstream.internals.KTableKTableJoinTest > testQueryableNotSendingOldValues PASSED org.apache.kafka.streams.kstream.internals.KTableKTableJoinTest > testSendingOldValues PASSED org.apache.kafka.streams.kstream.internals.KTableKTableJoinTest > testQueryableJoin PASSED org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoinTest > testSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoinTest > testJoin PASSED org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoinTest > testNotSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableMapValuesTest > testSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableMapValuesTest > testNotSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableMapValuesTest > testQueryableValueGetter PASSED org.apache.kafka.streams.kstream.internals.KTableMapValuesTest > testQueryableKTable PASSED org.apache.kafka.streams.kstream.internals.KTableMapValuesTest > testKTable PASSED org.apache.kafka.streams.kstream.internals.KTableMapValuesTest > testValueGetter PASSED org.apache.kafka.streams.kstream.internals.SessionKeySerdeTest > shouldConvertToBinaryAndBack PASSED org.apache.kafka.streams.kstream.internals.SessionKeySerdeTest > shouldExtractStartTimeFromBinary PASSED org.apache.kafka.streams.kstream.internals.SessionKeySerdeTest > shouldDeSerializeNullToNull PASSED org.apache.kafka.streams.kstream.internals.SessionKeySerdeTest > shouldSerializeDeserialize PASSED org.apache.kafka.streams.kstream.internals.SessionKeySerdeTest > shouldDeSerializeEmtpyByteArrayToNull PASSED org.apache.kafka.streams.kstream.internals.SessionKeySerdeTest > shouldExtractWindowFromBindary PASSED org.apache.kafka.streams.kstream.internals.SessionKeySerdeTest > shouldExtractKeyFromBinary PASSED org.apache.kafka.streams.kstream.internals.SessionKeySerdeTest > shouldExtractKeyBytesFromBinary PASSED org.apache.kafka.streams.kstream.internals.SessionKeySerdeTest > shouldExtractEndTimeFromBinary PASSED org.apache.kafka.streams.kstream.internals.SessionKeySerdeTest > shouldSerializeNullToNull PASSED org.apache.kafka.streams.kstream.internals.SessionKeySerdeTest > shouldExtractBytesKeyFromBinary PASSED org.apache.kafka.streams.kstream.internals.TimeWindowTest > shouldOverlapIfOtherWindowIsWithinThisWindow PASSED org.apache.kafka.streams.kstream.internals.TimeWindowTest > cannotCompareTimeWindowWithDifferentWindowType PASSED org.apache.kafka.streams.kstream.internals.TimeWindowTest > shouldNotOverlapIfOtherWindowIsBeforeThisWindow PASSED org.apache.kafka.streams.kstream.internals.TimeWindowTest > shouldOverlapIfOtherWindowContainsThisWindow PASSED org.apache.kafka.streams.kstream.internals.TimeWindowTest > shouldOverlapIfOtherWindowStartIsWithinThisWindow PASSED org.apache.kafka.streams.kstream.internals.TimeWindowTest > shouldOverlapIfOtherWindowEndIsWithinThisWindow PASSED org.apache.kafka.streams.kstream.internals.TimeWindowTest > shouldNotOverlapIsOtherWindowIsAfterThisWindow PASSED org.apache.kafka.streams.kstream.internals.TimeWindowTest > endMustBeLargerThanStart PASSED org.apache.kafka.streams.kstream.internals.WindowedStreamPartitionerTest > testCopartitioning PASSED org.apache.kafka.streams.kstream.internals.WindowedStreamPartitionerTest > testWindowedSerializerNoArgConstructors PASSED org.apache.kafka.streams.kstream.internals.WindowedStreamPartitionerTest > testWindowedDeserializerNoArgConstructors PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldAddRegexTopicToLatestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldMapStateStoresToCorrectSourceTopics PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldAddTableToEarliestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldAddTimestampExtractorToTablePerSource PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldBuildGlobalTopologyWithAllGlobalTables PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldAddRegexTopicToEarliestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldAddTopicToEarliestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldNotTryProcessingFromSinkTopic PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldHaveCorrectSourceTopicsForTableFromMergedStream PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > testNewStoreName PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > testMerge PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > testFrom PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldAddTopicToLatestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > kStreamTimestampExtractorShouldBeNull PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldBuildSimpleGlobalTableTopology PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldTryProcessingFromThoughTopic PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldAddTableToLatestAutoOffsetResetList PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldNotAddTableToOffsetResetLists PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldAddTimestampExtractorToStreamWithKeyValSerdePerSource PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldAddTimestampExtractorToTableWithKeyValSerdePerSource PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldAddGlobalTablesToEachGroup PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldNotAddRegexTopicsToOffsetResetLists PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldThrowExceptionWhenTopicNamesAreNull PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldThrowExceptionWhenNoTopicPresent PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > kTableTimestampExtractorShouldBeNull PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > testNewName PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldBuildGlobalTopologyWithAllGlobalTablesWithInternalStoreName PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldStillMaterializeSourceKTableIfStateNameNotSpecified PASSED org.apache.kafka.streams.kstream.KStreamBuilderTest > shouldAddTimestampExtractorToStreamWithOffsetResetPerSource PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > shouldComputeWindowsForHoppingWindows PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > shouldSetWindowAdvance PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > shouldComputeWindowsForTumblingWindows PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > shouldHaveSaneEqualsAndHashCode PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > shouldComputeWindowsForBarelyOverlappingHoppingWindows PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > shouldSetWindowSize PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > windowSizeMustNotBeZero PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > advanceIntervalMustNotBeZero PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > windowSizeMustNotBeNegative PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > advanceIntervalMustNotBeNegative PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > shouldSetWindowRetentionTime PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > advanceIntervalMustNotBeLargerThanWindowSize PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > retentionTimeMustNoBeSmallerThanWindowSize PASSED org.apache.kafka.streams.kstream.TimeWindowsTest > shouldUseWindowSizeAsRentitionTimeIfWindowSizeIsLargerThanDefaultRetentionTime PASSED org.apache.kafka.streams.kstream.WindowTest > shouldThrowIfEndIsSmallerThanStart PASSED org.apache.kafka.streams.kstream.WindowTest > shouldNotBeEqualIfDifferentWindowType PASSED org.apache.kafka.streams.kstream.WindowTest > shouldBeEqualIfStartAndEndSame PASSED org.apache.kafka.streams.kstream.WindowTest > shouldNotBeEqualIfNull PASSED org.apache.kafka.streams.kstream.WindowTest > shouldThrowIfStartIsNegative PASSED org.apache.kafka.streams.kstream.WindowTest > shouldNotBeEqualIfStartOrEndIsDifferent PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnRegisterWhenContextIsInitialized PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnTimestampFromRecordContext PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnOffsetFromRecordContext PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnPartitionFromRecordContext PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnTopicFromRecordContext PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowNullPointerOnRegisterIfStateStoreIsNull PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldNotThrowIllegalStateExceptionOnRegisterWhenContextIsNotInitialized PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnTimestampIfNoRecordContext PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnPartitionIfNoRecordContext PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnTopicIfNoRecordContext PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnOffsetIfNoRecordContext PASSED org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnNullIfTopicEqualsNonExistTopic PASSED org.apache.kafka.streams.processor.internals.CopartitionedTopicsValidatorTest > shouldSetNumPartitionsToMaximumPartitionsWhenAllTopicsAreRepartitionTopics PASSED org.apache.kafka.streams.processor.internals.CopartitionedTopicsValidatorTest > shouldSetRepartitionTopicsPartitionCountToNotAvailableIfAnyNotAvaliable PASSED org.apache.kafka.streams.processor.internals.CopartitionedTopicsValidatorTest > shouldThrowTopologyBuilderExceptionIfNoPartitionsFoundForCoPartitionedTopic PASSED org.apache.kafka.streams.processor.internals.CopartitionedTopicsValidatorTest > shouldThrowTopologyBuilderExceptionIfPartitionCountsForCoPartitionedTopicsDontMatch PASSED org.apache.kafka.streams.processor.internals.CopartitionedTopicsValidatorTest > shouldEnforceCopartitioningOnRepartitionTopics PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldCloseStateManagerWithOffsets PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldProcessRecordsForTopic PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldInitializeProcessorTopology PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldInitializeContext PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldCheckpointOffsetsWhenStateIsFlushed PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldThrowStreamsExceptionWhenKeyDeserializationFails PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldInitializeStateManager PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldProcessRecordsForOtherTopic PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldNotThrowStreamsExceptionWhenValueDeserializationFails PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldThrowStreamsExceptionWhenValueDeserializationFails PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldNotThrowStreamsExceptionWhenKeyDeserializationFailsWithSkipHandler PASSED org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHaveCompactionPropSetIfSupplied PASSED org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldThrowIfNameIsNull PASSED org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldConfigureRetentionMsWithAdditionalRetentionWhenCompactAndDelete PASSED org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldBeCompactedIfCleanupPolicyCompactOrCompactAndDelete PASSED org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotBeCompactedWhenCleanupPolicyIsDelete PASSED org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldHavePropertiesSuppliedByUser PASSED org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldThrowIfNameIsInvalid PASSED org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldUseCleanupPolicyFromConfigIfSupplied PASSED org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenCompact PASSED org.apache.kafka.streams.processor.internals.InternalTopicConfigTest > shouldNotConfigureRetentionMsWhenDelete PASSED org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnNotKnownTimestampWhenNoRecordsEverAdded PASSED org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldThrowNullPointerExceptionWhenTryingToAddNullElement PASSED org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLowestAvailableTimestampFromAllInputs PASSED org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnTimestampOfOnlyRecord PASSED org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLowestAvailableTimestampAfterPreviousLowestRemoved PASSED org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldIgnoreNullRecordOnRemove PASSED org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLastKnownTimestampWhenAllElementsHaveBeenRemoved PASSED org.apache.kafka.streams.processor.internals.ProcessorNodeTest > shouldThrowStreamsExceptionIfExceptionCaughtDuringInit PASSED org.apache.kafka.streams.processor.internals.ProcessorNodeTest > testMetrics PASSED org.apache.kafka.streams.processor.internals.ProcessorNodeTest > shouldThrowStreamsExceptionIfExceptionCaughtDuringClose PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingMultiplexingTopology PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > shouldCreateStringWithProcessors PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingForwardToSourceTopology PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingStatefulTopology PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingInternalRepartitioningTopology PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingInternalRepartitioningForwardingTimestampTopology PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingSimpleTopology PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingSimpleMultiSourceTopology PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > shouldDriveGlobalStore PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > shouldCreateStringWithMultipleSourcesAndTopics PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testTopologyMetadata PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > testDrivingMultiplexByNameTopology PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > shouldCreateStringWithSourceAndTopics PASSED org.apache.kafka.streams.processor.internals.ProcessorTopologyTest > shouldRecursivelyPrintChildren PASSED org.apache.kafka.streams.processor.internals.QuickUnionTest > testUnite PASSED org.apache.kafka.streams.processor.internals.QuickUnionTest > testUniteMany PASSED org.apache.kafka.streams.processor.internals.RecordQueueTest > testTimeTracking PASSED org.apache.kafka.streams.processor.internals.RecordQueueTest > shouldDropOnNegativeTimestamp PASSED org.apache.kafka.streams.processor.internals.RecordQueueTest > shouldNotThrowStreamsExceptionWhenValueDeserializationFailsWithSkipHandler PASSED org.apache.kafka.streams.processor.internals.RecordQueueTest > shouldThrowOnNegativeTimestamp PASSED org.apache.kafka.streams.processor.internals.RecordQueueTest > shouldThrowStreamsExceptionWhenKeyDeserializationFails PASSED org.apache.kafka.streams.processor.internals.RecordQueueTest > shouldThrowStreamsExceptionWhenValueDeserializationFails PASSED org.apache.kafka.streams.processor.internals.RecordQueueTest > shouldNotThrowStreamsExceptionWhenKeyDeserializationFailsWithSkipHandler PASSED org.apache.kafka.streams.processor.internals.SourceNodeRecordDeserializerTest > shouldThrowStreamsExceptionIfKeyValueFailsToDeserialize PASSED org.apache.kafka.streams.processor.internals.SourceNodeRecordDeserializerTest > shouldReturnNewConsumerRecordWithDeserializedValueWhenNoExceptions PASSED org.apache.kafka.streams.processor.internals.SourceNodeRecordDeserializerTest > shouldThrowStreamsExceptionIfKeyFailsToDeserialize PASSED org.apache.kafka.streams.processor.internals.StandbyTaskTest > shouldNotThrowUnsupportedOperationExceptionWhenInitializingStateStores PASSED org.apache.kafka.streams.processor.internals.StandbyTaskTest > shouldCheckpointStoreOffsetsOnCommit PASSED org.apache.kafka.streams.processor.internals.StandbyTaskTest > testStorePartitions PASSED org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateKTable PASSED org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdateNonPersistentStore PASSED org.apache.kafka.streams.processor.internals.StandbyTaskTest > testUpdate PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCleanUpTaskStateDirectoriesThatAreNotCurrentlyLocked PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateBaseDirectory PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldThrowProcessorStateException PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockMulitpleTaskDirectories PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateDirectoriesIfParentDoesntExist PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldUnlockGlobalStateDirectory PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldListAllTaskDirectories PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCleanupStateDirectoriesWhenLastModifiedIsLessThanNowMinusCleanupDelay PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockTaskStateDirectory PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldLockGlobalStateDirectory PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldNotLockDeletedDirectory PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldCreateTaskStateDirectory PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldNotRemoveNonTaskDirectoriesAndFiles PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldBeTrueIfAlreadyHoldsLock PASSED org.apache.kafka.streams.processor.internals.StateDirectoryTest > shouldReleaseTaskStateDirectoryLock PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldThrowExceptionIfConsumerHasCurrentSubscription PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldRestoreMultipleStores PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldNotReturnRestoredOffsetsForNonPersistentStore PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldRestoreToLimitWhenSupplied PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldNotRestoreAnythingWhenPartitionIsEmpty PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldRestoreMessagesFromCheckpoint PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldClearAssignmentAtEndOfRestore PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldIgnoreNullKeysWhenRestoring PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldReturnRestoredOffsetsForPersistentStores PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldThrowStreamsExceptionIfPartitionDoesntExistAfterMaxWait PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldNotRestoreAnythingWhenCheckpointAtEndOffset PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldPassIfTopicPartitionExists PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldRequestPartitionInfoIfItDoesntExist PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldRestoreAllMessagesFromBeginningWhenCheckpointNull PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldThrowStreamsExceptionIfTimeoutOccursDuringPartitionsFor PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldThrowStreamsExceptionWhenTimeoutExceptionThrown PASSED org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest > shouldFallbackToPartitionsForIfPartitionNotInAllPartitionsList PASSED org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > testEncodeDecode PASSED org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldDecodePreviousVersion PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotMigrateActiveTaskToOtherProcess PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignStandbyTasksToDifferentClientThanCorrespondingActiveTaskIsAssingedTo PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToNewClient PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignBasedOnCapacityWhenMultipleClientHaveStandbyTasks PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignBasedOnCapacity PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToNewClientWithoutFlippingAssignmentBetweenExistingAndBouncedClients PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignMultipleReplicasOfStandbyTask PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignNewTasksToNewClientWhenPreviousTasksAssignedToOldClients PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToNewClientWithoutFlippingAssignmentBetweenExistingClients PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignAtLeastOneTaskToEachClientIfPossible PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHosts PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldRebalanceTasksToClientsBasedOnCapacity PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousStandbyTasks PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotAssignStandbyTaskReplicasWhenNoClientAvailableWithoutHavingTheTaskAssigned PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignEachActiveTaskToOneClientWhenMoreClientsThanTasks PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToNewClient PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignOneActiveTaskToEachProcessWhenTaskCountSameAsProcessCount PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossClientsWhenCapacityLessThanTaskCount PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldBalanceActiveAndStandbyTasksAcrossAvailableClients PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignActiveAndStandbyTasks PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousActiveTasks PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToClientWithPreviousStandbyTasks PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossAllClientsWhenCapacityAndTaskCountTheSame PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignMoreTasksToClientWithMoreCapacity PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMigrateActiveTasksToNewProcessWithoutChangingAllAssignments PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldKeepActiveTaskStickynessWhenMoreClientThanActiveTasks PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotMoveAnyTasksWhenNewTasksAdded PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToMultipleNewClients PASSED org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMoveMinimalNumberOfTasksWhenPreviouslyAboveCapacityAndNewClientAdded PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldWrapKafkaExceptionsWithStreamsExceptionAndAddContextWhenPunctuatingStreamTime PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldCheckpointOffsetsOnCommit PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldThrowIllegalStateExceptionIfCurrentNodeIsNotNullWhenPunctuateCalled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldSendOffsetsAndCommitTransactionButNotStartNewTransactionOnSuspendIfEosEnabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldNotAbortTransactionOnDirtyClosedIfEosDisabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > testProcessOrder PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > testCancelPunctuateStreamTime PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldNotThrowExceptionOnScheduleIfCurrentNodeIsNotNull PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldPunctuateSystemTimeWhenIntervalElapsed PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldNotInitOrBeginTransactionOnCreateIfEosDisabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldFlushRecordCollectorOnFlushState PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > testMaybePunctuateStreamTime PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldNotPunctuateSystemTimeWhenIntervalNotElapsed PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldNotStartNewTransactionOnResumeIfEosDisabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldAbortTransactionOnDirtyClosedIfEosEnabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldInitAndBeginTransactionOnCreateIfEosEnabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > testMetrics PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > testCancelPunctuateSystemTime PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldCloseProducerOnCloseWhenEosEnabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldWrapKafkaExceptionsWithStreamsExceptionAndAddContext PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldNotSendOffsetsAndCommitTransactionNorStartNewTransactionOnSuspendIfEosDisabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldCallPunctuateOnPassedInProcessorNode PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldThrowIllegalStateExceptionOnScheduleIfCurrentNodeIsNull PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldStartNewTransactionOnCommitIfEosEnabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldStartNewTransactionOnResumeIfEosEnabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldCommitTransactionOnSuspendEvenIfTransactionIsEmptyIfEosEnabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldNotCheckpointOffsetsOnCommitIfEosIsEnabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldThrowExceptionIfAnyExceptionsRaisedDuringCloseButStillCloseAllProcessorNodesTopology PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > testPauseResume PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldNotStartNewTransactionOnCommitIfEosDisabled PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldWrapKafkaExceptionsWithStreamsExceptionAndAddContextWhenPunctuatingDeprecated PASSED org.apache.kafka.streams.processor.internals.StreamTaskTest > shouldSetProcessorNodeOnContextBackToNullAfterSuccesfullPunctuate PASSED org.apache.kafka.streams.processor.internals.StreamsKafkaClientTest > testConfigFromStreamsConfig PASSED org.apache.kafka.streams.processor.internals.StreamsMetricsImplTest > testThroughputMetrics PASSED org.apache.kafka.streams.processor.internals.StreamsMetricsImplTest > testLatencyMetrics PASSED org.apache.kafka.streams.processor.internals.StreamsMetricsImplTest > testRemoveSensor PASSED org.apache.kafka.streams.processor.internals.StreamsMetricsImplTest > testRemoveNullSensor PASSED org.apache.kafka.streams.processor.internals.StreamsMetricsImplTest > testNullMetrics PASSED org.apache.kafka.streams.processor.FailOnInvalidTimestampTest > failOnInvalidTimestamp PASSED org.apache.kafka.streams.processor.FailOnInvalidTimestampTest > extractMetadataTimestamp PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotAllowOffsetResetSourceWithDuplicateSourceName PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotAllowNullProcessorSupplier PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotSetApplicationIdToNull PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testSourceTopics PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotAllowNullNameWhenAddingSink PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testNamedTopicMatchesAlreadyProvidedPattern PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddInternalTopicConfigWithCompactAndDeleteSetForWindowStores PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddInternalTopicConfigWithCompactForNonWindowStores PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddTimestampExtractorWithOffsetResetAndPatternPerSource PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkWithSameName PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkWithSelfParent PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddProcessorWithSelfParent PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAssociateStateStoreNameWhenStateStoreSupplierIsInternal PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithSink PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testTopicGroups PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testBuild PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotAllowOffsetResetSourceWithoutTopics PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotAddNullStateStoreSupplier PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotAllowNullNameWhenAddingSource PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotAllowNullTopicWhenAddingSink PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotAllowToAddGlobalStoreWithSourceNameEqualsProcessorName PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddSourceWithOffsetReset PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithSource PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldThroughOnUnassignedStateStoreAccess PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotAllowNullProcessorNameWhenConnectingProcessorAndStateStores PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSourceWithSameName PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddTimestampExtractorWithOffsetResetPerSource PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddMoreThanOnePatternSourceNode PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddTimestampExtractorWithPatternPerSource PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddProcessorWithSameName PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldSetCorrectSourceNodesWithRegexUpdatedTopics PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSourceWithSameTopic PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testTopicGroupsByStateStore PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddSourceWithoutOffsetReset PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithDuplicates PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddTimestampExtractorPerSource PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddTimestampExtractorWithOffsetResetAndKeyValSerdesPerSource PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testPatternSourceTopic PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAssociateStateStoreNameWhenStateStoreSupplierIsExternal PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkWithWrongParent PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testPatternMatchesAlreadyProvidedTopicSource PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkConnectedWithMultipleParent PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddTimestampExtractorWithOffsetResetAndKeyValSerdesAndPatternPerSource PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testSubscribeTopicNameAndPattern PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddPatternSourceWithoutOffsetReset PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotAddNullInternalTopic PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddProcessorWithWrongParent PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldNotAllowNullNameWhenAddingProcessor PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddSourcePatternWithOffsetReset PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStore PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddSinkConnectedWithParent PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > testAddStateStoreWithNonExistingProcessor PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAddInternalTopicConfigWithCleanupPolicyDeleteForInternalTopics PASSED org.apache.kafka.streams.processor.TopologyBuilderTest > shouldCorrectlyMapStateStoreToInternalTopics PASSED org.apache.kafka.streams.processor.WallclockTimestampExtractorTest > extractSystemTimestamp PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutAllWithNullKey PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldIterateAllStoredItems PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldDeleteItemsFromCache PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldPutAll PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowIfTryingToDoRangeQueryOnClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowIfTryingToDoGetApproxSizeOnClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldIterateOverRange PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowIfTryingToGetFromClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldClearNamespaceCacheOnClose PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldReturnUnderlying PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowIfTryingToDeleteFromClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowIfTryingToDoPutIfAbsentClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowIfTryingToDoAllQueryOnClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldNotShowItemsDeletedFromCacheButFlushedToStoreBeforeDelete PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldForwardDirtyItemsWhenFlushCalled PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldFlushEvictedItemsIntoUnderlyingStore PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutIfAbsentWithNullKey PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldPutIfAbsent PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldPutGetToFromCache PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutWithNullKey PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowIfTryingToDoPutAllClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldForwardOldValuesWhenEnabled PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowIfTryingToWriteToClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldForwardDirtyItemToListenerWhenEvicted PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldNotThrowNullPointerExceptionOnPutIfAbsentNullValue PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutAllNullKey PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > testSize PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldNotThrowNullPointerExceptionOnPutNullValue PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutIfAbsentNullKey PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > testPutIfAbsent PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > testRestoreWithDefaultSerdes PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutNullKey PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > testRestore PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowNullPointerExceptionOnRangeNullToKey PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldNotThrowNullPointerExceptionOnPutAllNullKey PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > testPutGetRange PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowNullPointerExceptionOnGetNullKey PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowNullPointerExceptionOnRangeNullFromKey PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > shouldThrowNullPointerExceptionOnDeleteNullKey PASSED org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest > testPutGetRangeWithDefaultSerdes PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldPutFetchAllKeysFromCache PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowIfTryingToFindMergeSessionFromClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldPutFetchFromCache PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldForwardChangedValuesDuringFlush PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldPutFetchRangeFromCache PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldRemove PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldFetchRangeCorrectlyAcrossSegments PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowIfTryingToPutIntoClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowNullPointerExceptionOnRemoveNullKey PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldFlushItemsToStoreOnEviction PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldClearNamespaceCacheOnClose PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowNullPointerExceptionOnFetchNullFromKey PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowNullPointerExceptionOnFindSessionsNullFromKey PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldFetchAllSessionsWithSameRecordKey PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowNullPointerExceptionOnFetchNullToKey PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowNullPointerExceptionOnPutNullKey PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowIfTryingToFetchFromClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldQueryItemsInCacheAndStore PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowNullPointerExceptionOnFindSessionsNullToKey PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowNullPointerExceptionOnFindSessionsNullKey PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowIfTryingToRemoveFromClosedCachingStore PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldFetchCorrectlyAcrossSegments PASSED org.apache.kafka.streams.state.internals.CachingSessionStoreTest > shouldThrowNullPointerExceptionOnFetchNullKey PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldWriteAllKeyValueToInnerStoreOnPutAll PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldLogChangeOnPut PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldWriteToChangelogOnPutIfAbsentWhenNoPreviousValue PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldPutNullOnDelete PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldWriteToInnerOnPutIfAbsentNoPreviousValue PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldWriteKeyValueBytesToInnerStoreOnPut PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldReturnCurrentValueOnPutIfAbsent PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldLogChangesOnPutAll PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldNotWriteToChangeLogOnPutIfAbsentWhenValueForKeyExists PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldReturnNullOnPutIfAbsentWhenNoPreviousValue PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldLogKeyNullOnDelete PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldReturnNullOnGetWhenDoesntExist PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldReturnOldValueOnDelete PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldNotWriteToInnerOnPutIfAbsentWhenValueForKeyExists PASSED org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest > shouldReturnValueOnGetWhenExists PASSED org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > shouldFlushUnderlyingStore PASSED org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > shouldCloseUnderlyingStore PASSED org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > shouldLogPuts PASSED org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > shouldInitUnderlyingStore PASSED org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > shouldLogRemoves PASSED org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > shouldDelegateToUnderlyingStoreWhenFetching PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest > shouldNotGetValueFromOtherStores PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest > shouldReturnEmptyIteratorIfNoData PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest > shouldThrowInvalidStateStoreExceptionIfSessionFetchThrows PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest > shouldFindValueForKeyWhenMultiStores PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest > shouldThrowNullPointerExceptionIfFetchingNullKey PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest > shouldFetchResulstFromUnderlyingSessionStore PASSED org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest > shouldThrowInvalidStateStoreExceptionOnRebalance PASSED org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest > shouldPeekNext PASSED org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest > shouldPeekAndIterate PASSED org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest > shouldThrowNoSuchElementWhenNoMoreItemsLeftAndPeekNextCalled PASSED org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest > shouldThrowNoSuchElementWhenNoMoreItemsLeftAndNextCalled PASSED org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest > shouldPeekNextKey PASSED org.apache.kafka.streams.state.internals.GlobalStateStoreProviderTest > shouldReturnSingleItemListIfStoreExists PASSED org.apache.kafka.streams.state.internals.GlobalStateStoreProviderTest > shouldReturnEmptyItemListIfStoreDoesntExist PASSED org.apache.kafka.streams.state.internals.GlobalStateStoreProviderTest > shouldThrowExceptionIfStoreIsntOpen PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > shouldNotThrowNullPointerExceptionOnPutIfAbsentNullValue PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutAllNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > testSize PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > shouldNotThrowNullPointerExceptionOnPutNullValue PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutIfAbsentNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > testPutIfAbsent PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > testRestoreWithDefaultSerdes PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > shouldThrowNullPointerExceptionOnPutNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > testRestore PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > shouldThrowNullPointerExceptionOnRangeNullToKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > shouldNotThrowNullPointerExceptionOnPutAllNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > testPutGetRange PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > shouldThrowNullPointerExceptionOnGetNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > shouldThrowNullPointerExceptionOnRangeNullFromKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > shouldThrowNullPointerExceptionOnDeleteNullKey PASSED org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest > testPutGetRangeWithDefaultSerdes PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueStoreIteratorTest > shouldNotHaveNextIfOnlyCacheItemsAndAllDeleted PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueStoreIteratorTest > shouldNotHaveNextIfAllCachedItemsDeleted PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueStoreIteratorTest > shouldIterateOverRange PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueStoreIteratorTest > shouldIgnoreIfDeletedInCacheButExistsInStore PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueStoreIteratorTest > shouldSkipAllDeletedFromCache PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueStoreIteratorTest > shouldSkipLargerDeletedCacheValue PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueStoreIteratorTest > shouldSkipSmallerDeletedCachedValue PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueStoreIteratorTest > shouldPeekNextKey PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreIteratorTest > shouldIterateOverValueFromBothIterators PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreIteratorTest > shouldPeekNextCacheKey PASSED org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreIteratorTest > shouldPeekNextStoreKey PASSED org.apache.kafka.streams.state.internals.MeteredSegmentedBytesStoreTest > shouldRecordFetchLatency PASSED org.apache.kafka.streams.state.internals.MeteredSegmentedBytesStoreTest > shouldCloseUnderlyingStore PASSED org.apache.kafka.streams.state.internals.MeteredSegmentedBytesStoreTest > shouldRecordFlushLatency PASSED org.apache.kafka.streams.state.internals.MeteredSegmentedBytesStoreTest > shouldRecordPutLatency PASSED org.apache.kafka.streams.state.internals.MeteredSegmentedBytesStoreTest > shouldRecordRestoreLatencyOnInit PASSED org.apache.kafka.streams.state.internals.MeteredSegmentedBytesStoreTest > shouldRecordGetLatency PASSED org.apache.kafka.streams.state.internals.MeteredSegmentedBytesStoreTest > shouldRecordRemoveLatency PASSED org.apache.kafka.streams.state.internals.OffsetCheckpointTest > testReadWrite PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest > shouldCreateLoggingEnabledStoreWhenStoreLogged PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest > shouldReturnCachedKeyValueStoreWhenCachingEnabled PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest > shouldReturnMeteredStoreWhenCachingAndLoggingDisabled PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest > shouldNotBeLoggingEnabledStoreWhenLoggingNotEnabled PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest > shouldHaveMeteredStoreWhenCached PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest > shouldReturnMeteredStoreWhenCachingDisabled PASSED org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplierTest > shouldHaveMeteredStoreWhenLogged PASSED org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStoreTest > shouldRemove PASSED org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStoreTest > shouldPutAndFetch PASSED org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStoreTest > shouldRollSegments PASSED org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStoreTest > shouldFindValuesWithinRange PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreSupplierTest > shouldHaveMeteredStoreWhenNotLoggedOrCached PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreSupplierTest > shouldReturnRocksDbStoreWhenCachingDisabled PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreSupplierTest > shouldNotBeLoggingEnabledStoreWhenLogginNotEnabled PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreSupplierTest > shouldBeCachedWindowStoreWhenCachingEnabled PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreSupplierTest > shouldHaveMeteredStoreWhenCached PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreSupplierTest > shouldCreateLoggingEnabledStoreWhenWindowStoreLogged PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreSupplierTest > shouldThrowIllegalArgumentExceptionIfNumSegmentsLessThanTwo PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreSupplierTest > shouldHaveMeteredStoreWhenLogged PASSED org.apache.kafka.streams.state.internals.RocksDBWindowStoreSupplierTest > shouldReturnRocksDbStoreWhenCachingAndLoggingDisabled PASSED org.apache.kafka.streams.state.internals.SegmentIteratorTest > shouldThrowNoSuchElementOnNextIfNoNext PASSED org.apache.kafka.streams.state.internals.SegmentIteratorTest > shouldThrowNoSuchElementOnPeekNextKeyIfNoNext PASSED org.apache.kafka.streams.state.internals.SegmentIteratorTest > shouldIterateOverAllSegments PASSED org.apache.kafka.streams.state.internals.SegmentIteratorTest > shouldOnlyIterateOverSegmentsInRange PASSED org.apache.kafka.streams.state.internals.SegmentsTest > shouldCleanupSegmentsThatHaveExpired PASSED org.apache.kafka.streams.state.internals.SegmentsTest > shouldBaseSegmentIntervalOnRetentionAndNumSegments PASSED org.apache.kafka.streams.state.internals.SegmentsTest > shouldCloseAllOpenSegments PASSED org.apache.kafka.streams.state.internals.SegmentsTest > shouldGetSegmentsWithinTimeRange PASSED org.apache.kafka.streams.state.internals.SegmentsTest > shouldNotCreateSegmentThatIsAlreadyExpired PASSED org.apache.kafka.streams.state.internals.SegmentsTest > shouldCreateSegments PASSED org.apache.kafka.streams.state.internals.SegmentsTest > shouldOpenExistingSegments PASSED org.apache.kafka.streams.state.internals.SegmentsTest > shouldGetSegmentIdsFromTimestamp PASSED org.apache.kafka.streams.state.internals.SegmentsTest > shouldRollSegments PASSED org.apache.kafka.streams.state.internals.SegmentsTest > shouldGetSegmentNameFromId PASSED org.apache.kafka.streams.state.internals.SegmentsTest > shouldGetSegmentForTimestamp PASSED org.apache.kafka.streams.state.internals.SessionKeySchemaTest > testUpperBoundWithLargeTimestamps PASSED org.apache.kafka.streams.state.internals.SessionKeySchemaTest > testUpperBoundWithZeroTimestamp PASSED org.apache.kafka.streams.state.internals.SessionKeySchemaTest > testLowerBoundMatchesTrailingZeros PASSED org.apache.kafka.streams.state.internals.SessionKeySchemaTest > testUpperBoundWithKeyBytesLargerThanFirstTimestampByte PASSED org.apache.kafka.streams.state.internals.SessionKeySchemaTest > shouldFetchExactKeySkippingShorterKeys PASSED org.apache.kafka.streams.state.internals.SessionKeySchemaTest > shouldFetchExactKeysSkippingLongerKeys PASSED org.apache.kafka.streams.state.internals.SessionKeySchemaTest > testLowerBoundWithZeroTimestamp PASSED org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest > shouldReturnEmptyListIfNoStoresFoundWithName PASSED org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest > shouldThrowInvalidStoreExceptionIfKVStoreClosed PASSED org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest > shouldThrowInvalidStoreExceptionIfNotAllStoresAvailable PASSED org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest > shouldFindWindowStores PASSED org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest > shouldReturnEmptyListIfStoreExistsButIsNotOfTypeValueStore PASSED org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest > shouldFindKeyValueStores PASSED org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest > shouldThrowInvalidStoreExceptionIfWindowStoreClosed PASSED org.apache.kafka.streams.state.internals.WindowStoreUtilsTest > testSerialization PASSED org.apache.kafka.streams.state.internals.RocksDBStoreTest > shouldThrowNullPointerExceptionOnDelete PASSED org.apache.kafka.streams.state.internals.RocksDBStoreTest > shouldPutAll PASSED org.apache.kafka.streams.state.internals.RocksDBStoreTest > shouldThrowProcessorStateExeptionOnPutDeletedDir PASSED org.apache.kafka.streams.state.internals.RocksDBStoreTest > canSpecifyConfigSetterAsString PASSED org.apache.kafka.streams.state.internals.RocksDBStoreTest > shouldThrowNullPointerExceptionOnNullGet PASSED org.apache.kafka.streams.state.internals.RocksDBStoreTest > shouldThrowNullPointerExceptionOnNullPut PASSED org.apache.kafka.streams.state.internals.RocksDBStoreTest > canSpecifyConfigSetterAsClass PASSED org.apache.kafka.streams.state.internals.RocksDBStoreTest > shouldThrowNullPointerExceptionOnNullPutAll PASSED org.apache.kafka.streams.state.internals.RocksDBStoreTest > shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir PASSED org.apache.kafka.streams.state.internals.RocksDBStoreTest > shouldThrowNullPointerExceptionOnRange PASSED org.apache.kafka.streams.KafkaStreamsTest > testIllegalMetricsConfig PASSED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWhenNotRunning PASSED org.apache.kafka.streams.KafkaStreamsTest > testInitializesAndDestroysMetricsReporters PASSED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndPartitionerWhenNotRunning PASSED org.apache.kafka.streams.KafkaStreamsTest > testLegalMetricsConfig PASSED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetTaskWithKeyAndSerializerWhenNotRunning PASSED org.apache.kafka.streams.KafkaStreamsTest > testToString PASSED org.apache.kafka.streams.KafkaStreamsTest > testStateCloseAfterCreate PASSED org.apache.kafka.streams.KafkaStreamsTest > shouldReturnFalseOnCloseWhenThreadsHaventTerminated PASSED org.apache.kafka.streams.KafkaStreamsTest > shouldNotGetAllTasksWithStoreWhenNotRunning PASSED org.apache.kafka.streams.KafkaStreamsTest > testCannotStartOnceClosed PASSED org.apache.kafka.streams.KafkaStreamsTest > testStateGlobalThreadClose PASSED org.apache.kafka.streams.KafkaStreamsTest > testCleanup PASSED org.apache.kafka.streams.KafkaStreamsTest > testNumberDefaultMetrics PASSED org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent PASSED org.apache.kafka.streams.KafkaStreamsTest > testCannotCleanupWhileRunning PASSED org.apache.kafka.streams.KafkaStreamsTest > testStateThreadClose PASSED org.apache.kafka.streams.KafkaStreamsTest > testStateChanges PASSED org.apache.kafka.streams.KafkaStreamsTest > testCannotStartTwice PASSED org.apache.kafka.streams.StreamsConfigTest > shouldUseNewConfigsWhenPresent PASSED org.apache.kafka.streams.StreamsConfigTest > testGetConsumerConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > shouldAcceptAtLeastOnce PASSED org.apache.kafka.streams.StreamsConfigTest > shouldUseCorrectDefaultsWhenNoneSpecified PASSED org.apache.kafka.streams.StreamsConfigTest > shouldAllowSettingProducerEnableIdempotenceIfEosDisabled PASSED org.apache.kafka.streams.StreamsConfigTest > defaultSerdeShouldBeConfigured PASSED org.apache.kafka.streams.StreamsConfigTest > shouldSetDifferentDefaultsIfEosEnabled PASSED org.apache.kafka.streams.StreamsConfigTest > shouldNotOverrideUserConfigRetriesIfExactlyOnceEnabled PASSED org.apache.kafka.streams.StreamsConfigTest > shouldSupportPrefixedConsumerConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > shouldOverrideStreamsDefaultConsumerConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > testGetProducerConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > shouldAllowSettingProducerMaxInFlightRequestPerConnectionsWhenEosDisabled PASSED org.apache.kafka.streams.StreamsConfigTest > shouldThrowStreamsExceptionIfValueSerdeConfigFails PASSED org.apache.kafka.streams.StreamsConfigTest > shouldThrowExceptionIfNotAtLestOnceOrExactlyOnce PASSED org.apache.kafka.streams.StreamsConfigTest > shouldAllowSettingConsumerIsolationLevelIfEosDisabled PASSED org.apache.kafka.streams.StreamsConfigTest > shouldThrowExceptionIfConsumerAutoCommitIsOverridden PASSED org.apache.kafka.streams.StreamsConfigTest > shouldSupportPrefixedProducerConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > shouldSupportPrefixedPropertiesThatAreNotPartOfRestoreConsumerConfig PASSED org.apache.kafka.streams.StreamsConfigTest > shouldOverrideStreamsDefaultProducerConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > shouldSupportPrefixedPropertiesThatAreNotPartOfProducerConfig PASSED org.apache.kafka.streams.StreamsConfigTest > shouldBeBackwardsCompatibleWithDeprecatedConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > shouldBeSupportNonPrefixedConsumerConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > shouldOverrideStreamsDefaultConsumerConifgsOnRestoreConsumer PASSED org.apache.kafka.streams.StreamsConfigTest > shouldThrowExceptionIfRestoreConsumerAutoCommitIsOverridden PASSED org.apache.kafka.streams.StreamsConfigTest > shouldAcceptExactlyOnce PASSED org.apache.kafka.streams.StreamsConfigTest > shouldSetInternalLeaveGroupOnCloseConfigToFalseInConsumer PASSED org.apache.kafka.streams.StreamsConfigTest > shouldSupportPrefixedPropertiesThatAreNotPartOfConsumerConfig PASSED org.apache.kafka.streams.StreamsConfigTest > shouldNotOverrideUserConfigCommitIntervalMsIfExactlyOnceEnabled PASSED org.apache.kafka.streams.StreamsConfigTest > shouldSupportMultipleBootstrapServers PASSED org.apache.kafka.streams.StreamsConfigTest > shouldThrowExceptionIfConsumerIsolationLevelIsOverriddenIfEosEnabled PASSED org.apache.kafka.streams.StreamsConfigTest > shouldThrowStreamsExceptionIfKeySerdeConfigFails PASSED org.apache.kafka.streams.StreamsConfigTest > shouldSupportNonPrefixedProducerConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > testGetRestoreConsumerConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > shouldThrowExceptionIfBootstrapServersIsNotSet PASSED org.apache.kafka.streams.StreamsConfigTest > shouldBeSupportNonPrefixedRestoreConsumerConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > shouldSupportPrefixedRestoreConsumerConfigs PASSED org.apache.kafka.streams.StreamsConfigTest > shouldThrowExceptionIfApplicationIdIsNotSet PASSED org.apache.kafka.streams.StreamsConfigTest > shouldThrowExceptionIfProducerEnableIdempotenceIsOverriddenIfEosEnabled PASSED org.apache.kafka.streams.StreamsConfigTest > shouldThrowExceptionIfProducerMaxInFlightRequestPerConnectionsIsOverriddenIfEosEnabled PASSED BUILD SUCCESSFUL Total time: 9 mins 40.978 secs