登录注册

Jar文件详情内容

kafka-streams-2.3.0-test.jar

所在目录：/org/apache/kafka/kafka-streams/2.3.0 查看kafka-streams所有版本文件

组织ID:	org.apache.kafka
项目ID:	kafka-streams
版本:	2.3.0
最后修改时间:	2019-07-19 17:51:56
包类型:	jar
大小:	1.38MB

Maven引入代码:	`<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> <version>2.3.0</version> </dependency>`
Gradle引入代码:	`org.apache.kafka:kafka-streams:2.3.0`
下载Jar包:	kafka-streams-2.3.0-test.jar
Jar包内容:	展开复制 META-INF/MANIFEST.MF LICENSE NOTICE org.apache.kafka.streams.KafkaStreamsTest$1.class org.apache.kafka.streams.TopologyWrapper.class org.apache.kafka.streams.StreamsConfigTest$MisconfiguredSerde.class org.apache.kafka.streams.errors.AlwaysContinueProductionExceptionHandler.class org.apache.kafka.streams.KeyValueTest.class org.apache.kafka.streams.internals.ApiUtilsTest.class org.apache.kafka.streams.TopologyTest$1.class org.apache.kafka.streams.state.KeyValueStoreTestDriver$1.class org.apache.kafka.streams.state.internals.ReadOnlyWindowStoreStub$2.class org.apache.kafka.streams.state.internals.SessionStoreBuilderTest.class org.apache.kafka.streams.state.internals.ChangeLoggingTimestampedWindowBytesStoreTest$1.class org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest$TheRocksDbConfigSetter.class org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest.class org.apache.kafka.streams.state.internals.ReadOnlyWindowStoreStub$1.class org.apache.kafka.streams.state.internals.TimetampedSegmentsTest.class org.apache.kafka.streams.state.internals.StoreChangeLoggerTest$1.class org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest$1.class org.apache.kafka.streams.state.internals.ChangeLoggingWindowBytesStoreTest$1.class org.apache.kafka.streams.state.internals.FilteredCacheIteratorTest$3.class org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest.class org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStoreTest.class org.apache.kafka.streams.state.internals.InMemoryTimeOrderedKeyValueBufferTest.class org.apache.kafka.streams.state.internals.NamedCacheTest$3.class org.apache.kafka.streams.state.internals.MeteredKeyValueStoreTest$CachedKeyValueStore.class org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest.class org.apache.kafka.streams.state.internals.FilteredCacheIteratorTest.class org.apache.kafka.streams.state.internals.ChangeLoggingTimestampedKeyValueBytesStoreTest.class org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest$2.class org.apache.kafka.streams.state.internals.MeteredWindowStoreTest.class org.apache.kafka.streams.state.internals.WindowKeySchemaTest.class org.apache.kafka.streams.state.internals.TimeOrderedKeyValueBufferTest.class org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStoreTest.class org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStoreTest.class org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest.class org.apache.kafka.streams.state.internals.KeyValueSegmentTest.class org.apache.kafka.streams.state.internals.RocksDBStoreTest$TestingBloomFilterRocksDBConfigSetter.class org.apache.kafka.streams.state.internals.ReadOnlyWindowStoreStub.class org.apache.kafka.streams.state.internals.WindowStoreBuilderTest.class org.apache.kafka.streams.state.internals.SegmentedCacheFunctionTest.class org.apache.kafka.streams.state.internals.ReadOnlyWindowStoreFacadeTest.class org.apache.kafka.streams.state.internals.CachingSessionStoreTest.class org.apache.kafka.streams.state.internals.MaybeTest.class org.apache.kafka.streams.state.internals.StoreChangeLoggerTest.class org.apache.kafka.streams.state.internals.AbstractKeyValueStoreTest$2.class org.apache.kafka.streams.state.internals.RecordConvertersTest.class org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest$CacheFlushListenerStub.class org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreIteratorTest$1.class org.apache.kafka.streams.state.internals.AbstractKeyValueStoreTest.class org.apache.kafka.streams.state.internals.MeteredSessionStoreTest.class org.apache.kafka.streams.state.internals.ThreadCacheTest.class org.apache.kafka.streams.state.internals.WindowBytesStoreTest$1.class org.apache.kafka.streams.state.internals.RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest$3.class org.apache.kafka.streams.state.internals.ChangeLoggingSessionBytesStoreTest$1.class org.apache.kafka.streams.state.internals.FilteredCacheIteratorTest$2.class org.apache.kafka.streams.state.internals.MeteredTimestampedWindowStoreTest.class org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest.class org.apache.kafka.streams.state.internals.RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest$1.class org.apache.kafka.streams.state.internals.ReadOnlyWindowStoreStub$3.class org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilderTest.class org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest$1.class org.apache.kafka.streams.state.internals.InMemorySessionStoreTest.class org.apache.kafka.streams.state.internals.KeyValueStoreBuilderTest.class org.apache.kafka.streams.state.internals.NamedCacheTest$4.class org.apache.kafka.streams.state.internals.SessionBytesStoreTest$1.class org.apache.kafka.streams.state.internals.RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest.class org.apache.kafka.streams.state.internals.FilteredCacheIteratorTest$1.class org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest.class org.apache.kafka.streams.state.internals.GlobalStateStoreProviderTest.class org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueBytesStoreIteratorTest.class org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedSessionStoreIteratorTest.class org.apache.kafka.streams.state.internals.ChangeLoggingSessionBytesStoreTest.class org.apache.kafka.streams.state.internals.InMemoryWindowStoreTest.class org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedSessionStoreIteratorTest$1.class org.apache.kafka.streams.state.internals.SerdeThatDoesntHandleNull$1.class org.apache.kafka.streams.state.internals.AbstractKeyValueStoreTest$1.class org.apache.kafka.streams.state.internals.ReadOnlyWindowStoreStub$TheWindowStoreIterator.class org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest.class org.apache.kafka.streams.state.internals.NamedCacheTest$1.class org.apache.kafka.streams.state.internals.RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest$2.class org.apache.kafka.streams.state.internals.NamedCacheTest$2.class org.apache.kafka.streams.state.internals.RocksDBWindowStoreTest.class org.apache.kafka.streams.state.internals.StreamThreadStateStoreProviderTest$1.class org.apache.kafka.streams.state.internals.RocksDBStoreTest.class org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest.class org.apache.kafka.streams.state.internals.QueryableStoreProviderTest.class org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStoreTest.class org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest.class org.apache.kafka.streams.state.internals.TimestampedSegmentTest.class org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest.class org.apache.kafka.streams.state.internals.AbstractRocksDBSegmentedBytesStoreTest.class org.apache.kafka.streams.state.internals.NamedCacheTest.class org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest$1.class org.apache.kafka.streams.state.internals.KeyValueIteratorFacadeTest.class org.apache.kafka.streams.state.internals.KeyValueSegmentsTest.class org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreTest.class org.apache.kafka.streams.state.internals.WrappingStoreProviderTest.class org.apache.kafka.streams.state.internals.MeteredKeyValueStoreTest.class org.apache.kafka.streams.state.internals.OffsetCheckpointTest.class org.apache.kafka.streams.state.internals.MeteredWindowStoreTest$CachedWindowStore.class org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest$3.class org.apache.kafka.streams.state.internals.MeteredTimestampedKeyValueStoreTest.class org.apache.kafka.streams.state.internals.SerdeThatDoesntHandleNull.class org.apache.kafka.streams.state.internals.ChangeLoggingTimestampedKeyValueBytesStoreTest$1.class org.apache.kafka.streams.state.internals.CachingWindowStoreTest.class org.apache.kafka.streams.state.internals.SegmentIteratorTest.class org.apache.kafka.streams.state.internals.CachingSessionStoreTest$CacheFlushListenerStub.class org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreIteratorTest.class org.apache.kafka.streams.state.internals.CachingWindowStoreTest$1.class org.apache.kafka.streams.state.internals.SessionKeySchemaTest.class org.apache.kafka.streams.state.internals.MeteredTimestampedKeyValueStoreTest$CachedKeyValueStore.class org.apache.kafka.streams.state.internals.SessionBytesStoreTest.class org.apache.kafka.streams.state.internals.RocksDBStoreTest$MockRocksDbConfigSetter.class org.apache.kafka.streams.state.internals.MeteredSessionStoreTest$CachedSessionStore.class org.apache.kafka.streams.state.internals.TimestampedKeyValueStoreBuilderTest.class org.apache.kafka.streams.state.internals.WindowBytesStoreTest.class org.apache.kafka.streams.state.internals.ReadOnlyKeyValueStoreFacadeTest.class org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStoreTest.class org.apache.kafka.streams.state.internals.ChangeLoggingTimestampedWindowBytesStoreTest.class org.apache.kafka.streams.state.internals.ChangeLoggingWindowBytesStoreTest.class org.apache.kafka.streams.state.KeyValueStoreTestDriver$2.class org.apache.kafka.streams.state.StoresTest.class org.apache.kafka.streams.state.NoOpWindowStore.class org.apache.kafka.streams.state.KeyValueStoreTestDriver.class org.apache.kafka.streams.state.StateSerdesTest.class org.apache.kafka.streams.state.NoOpWindowStore$1.class org.apache.kafka.streams.state.NoOpWindowStore$EmptyWindowStoreIterator.class org.apache.kafka.streams.kstream.WindowTest$TestWindow2.class org.apache.kafka.streams.kstream.PrintedTest.class org.apache.kafka.streams.kstream.SuppressedTest.class org.apache.kafka.streams.kstream.SessionWindowedDeserializerTest.class org.apache.kafka.streams.kstream.NamedTest.class org.apache.kafka.streams.kstream.PrintedTest$1.class org.apache.kafka.streams.kstream.TimeWindowedDeserializerTest.class org.apache.kafka.streams.kstream.internals.SessionCacheFlushListenerTest.class org.apache.kafka.streams.kstream.internals.KStreamTransformValuesTest$1.class org.apache.kafka.streams.kstream.internals.AbstractStreamTest.class org.apache.kafka.streams.kstream.internals.KStreamTransformTest.class org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest.class org.apache.kafka.streams.kstream.internals.KTableMapKeysTest.class org.apache.kafka.streams.kstream.internals.KTableMapValuesTest.class org.apache.kafka.streams.kstream.internals.KTableTransformValuesTest.class org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoinTest.class org.apache.kafka.streams.kstream.internals.KTableFilterTest.class org.apache.kafka.streams.kstream.internals.KTableReduceTest.class org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest$3.class org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest$1.class org.apache.kafka.streams.kstream.internals.KStreamTransformTest$2.class org.apache.kafka.streams.kstream.internals.SessionWindowedKStreamImplTest.class org.apache.kafka.streams.kstream.internals.KStreamTransformValuesTest$2.class org.apache.kafka.streams.kstream.internals.SuppressScenarioTest.class org.apache.kafka.streams.kstream.internals.TimestampedTupleForwarderTest.class org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest.class org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest.class org.apache.kafka.streams.kstream.internals.WindowedStreamPartitionerTest.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$2.class org.apache.kafka.streams.kstream.internals.KTableTransformValuesTest$NullSupplier.class org.apache.kafka.streams.kstream.internals.KTableKTableRightJoinTest.class org.apache.kafka.streams.kstream.internals.KTableTransformValuesTest$ExclamationValueTransformer.class org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest.class org.apache.kafka.streams.kstream.internals.KTableTransformValuesTest$1.class org.apache.kafka.streams.kstream.internals.KTableTransformValuesTest$StatefulTransformer.class org.apache.kafka.streams.kstream.internals.KTableTransformValuesTest$ExclamationValueTransformerSupplier.class org.apache.kafka.streams.kstream.internals.KStreamFlatTransformValuesTest.class org.apache.kafka.streams.kstream.internals.AbstractStreamTest$1.class org.apache.kafka.streams.kstream.internals.KStreamGlobalKTableJoinTest.class org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest.class org.apache.kafka.streams.kstream.internals.SessionTupleForwarderTest.class org.apache.kafka.streams.kstream.internals.KTableImplTest.class org.apache.kafka.streams.kstream.internals.MaterializedInternalTest.class org.apache.kafka.streams.kstream.internals.FullChangeSerdeTest.class org.apache.kafka.streams.kstream.internals.AbstractStreamTest$ExtendedKStreamDummy$ExtendedKStreamDummyProcessor.class org.apache.kafka.streams.kstream.internals.AbstractStreamTest$ExtendedKStream.class org.apache.kafka.streams.kstream.internals.KTableImplTest$1.class org.apache.kafka.streams.kstream.internals.TimestampedCacheFlushListenerTest.class org.apache.kafka.streams.kstream.internals.graph.GraphGraceSearchUtilTest.class org.apache.kafka.streams.kstream.internals.graph.GraphGraceSearchUtilTest$1.class org.apache.kafka.streams.kstream.internals.graph.TableProcessorNodeTest.class org.apache.kafka.streams.kstream.internals.graph.StreamsGraphTest.class org.apache.kafka.streams.kstream.internals.graph.TableProcessorNodeTest$1.class org.apache.kafka.streams.kstream.internals.graph.GraphGraceSearchUtilTest$2.class org.apache.kafka.streams.kstream.internals.graph.TableProcessorNodeTest$TestProcessor.class org.apache.kafka.streams.kstream.internals.KStreamFlatMapValuesTest.class org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest$2.class org.apache.kafka.streams.kstream.internals.GlobalKTableJoinsTest.class org.apache.kafka.streams.kstream.internals.SuppressTopologyTest.class org.apache.kafka.streams.kstream.internals.KStreamTransformTest$1.class org.apache.kafka.streams.kstream.internals.TransformerSupplierAdapterTest.class org.apache.kafka.streams.kstream.internals.KStreamFilterTest.class org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest$1.class org.apache.kafka.streams.kstream.internals.KStreamKTableJoinTest.class org.apache.kafka.streams.kstream.internals.suppress.KTableSuppressProcessorTest$1.class org.apache.kafka.streams.kstream.internals.suppress.SuppressSuite.class org.apache.kafka.streams.kstream.internals.suppress.KTableSuppressProcessorTest$Harness.class org.apache.kafka.streams.kstream.internals.suppress.KTableSuppressProcessorMetricsTest.class org.apache.kafka.streams.kstream.internals.suppress.KTableSuppressProcessorTest.class org.apache.kafka.streams.kstream.internals.KStreamImplTest.class org.apache.kafka.streams.kstream.internals.NamedInternalTest$TestNameProvider.class org.apache.kafka.streams.kstream.internals.SessionWindowTest.class org.apache.kafka.streams.kstream.internals.KTableTransformValuesTest$StatelessTransformerSupplier.class org.apache.kafka.streams.kstream.internals.KStreamGlobalKTableLeftJoinTest.class org.apache.kafka.streams.kstream.internals.KStreamForeachTest.class org.apache.kafka.streams.kstream.internals.KStreamKStreamLeftJoinTest.class org.apache.kafka.streams.kstream.internals.UnlimitedWindowTest.class org.apache.kafka.streams.kstream.internals.KTableTransformValuesTest$StatefulTransformerSupplier.class org.apache.kafka.streams.kstream.internals.KStreamFlatMapTest.class org.apache.kafka.streams.kstream.internals.KStreamWindowAggregateTest.class org.apache.kafka.streams.kstream.internals.KStreamTransformValuesTest.class org.apache.kafka.streams.kstream.internals.TimeWindowTest.class org.apache.kafka.streams.kstream.internals.KStreamPrintTest.class org.apache.kafka.streams.kstream.internals.KStreamSelectKeyTest.class org.apache.kafka.streams.kstream.internals.KStreamPeekTest.class org.apache.kafka.streams.kstream.internals.NamedInternalTest$1.class org.apache.kafka.streams.kstream.internals.KStreamBranchTest.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$1.class org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest.class org.apache.kafka.streams.kstream.internals.KTableTransformValuesTest$StatelessTransformer.class org.apache.kafka.streams.kstream.internals.KTableSourceTest.class org.apache.kafka.streams.kstream.internals.TimeWindowedKStreamImplTest.class org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest.class org.apache.kafka.streams.kstream.internals.KTableAggregateTest.class org.apache.kafka.streams.kstream.internals.InternalStreamsBuilderTest.class org.apache.kafka.streams.kstream.internals.NamedInternalTest.class org.apache.kafka.streams.kstream.internals.KStreamMapTest.class org.apache.kafka.streams.kstream.internals.AbstractStreamTest$ExtendedKStreamDummy.class org.apache.kafka.streams.kstream.internals.KStreamMapValuesTest.class org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest.class org.apache.kafka.streams.kstream.TimeWindowsTest.class org.apache.kafka.streams.kstream.WindowsTest.class org.apache.kafka.streams.kstream.WindowTest.class org.apache.kafka.streams.kstream.MaterializedTest.class org.apache.kafka.streams.kstream.UnlimitedWindowsTest.class org.apache.kafka.streams.kstream.RepartitionTopicNamingTest$SimpleProcessor.class org.apache.kafka.streams.kstream.RepartitionTopicNamingTest.class org.apache.kafka.streams.kstream.WindowTest$TestWindow.class org.apache.kafka.streams.kstream.JoinWindowsTest.class org.apache.kafka.streams.kstream.SessionWindowedSerializerTest.class org.apache.kafka.streams.kstream.TimeWindowedSerializerTest.class org.apache.kafka.streams.kstream.SessionWindowsTest.class org.apache.kafka.streams.kstream.WindowedSerdesTest.class org.apache.kafka.streams.kstream.WindowsTest$TestWindows.class org.apache.kafka.streams.kstream.WindowsTest$1.class org.apache.kafka.streams.StreamsBuilderTest.class org.apache.kafka.streams.perf.SimpleBenchmark$2$1.class org.apache.kafka.streams.perf.SimpleBenchmark$3.class org.apache.kafka.streams.perf.SimpleBenchmark$2.class org.apache.kafka.streams.perf.YahooBenchmark$JsonPOJOSerializer.class org.apache.kafka.streams.perf.SimpleBenchmark$1.class org.apache.kafka.streams.perf.SimpleBenchmark.class org.apache.kafka.streams.perf.SimpleBenchmark$4.class org.apache.kafka.streams.perf.YahooBenchmark.class org.apache.kafka.streams.perf.YahooBenchmark$CampaignAd.class org.apache.kafka.streams.perf.YahooBenchmark$ProjectedEvent.class org.apache.kafka.streams.perf.SimpleBenchmark$3$1.class org.apache.kafka.streams.perf.SimpleBenchmark$ZipfGenerator.class org.apache.kafka.streams.perf.SimpleBenchmark$CountDownAction.class org.apache.kafka.streams.perf.YahooBenchmark$JsonPOJODeserializer.class org.apache.kafka.streams.StreamsConfigTest$MockTimestampExtractor.class org.apache.kafka.streams.tests.SmokeTestDriver$TestCallback.class org.apache.kafka.streams.tests.EosTestDriver.class org.apache.kafka.streams.tests.StreamsUpgradeTest$1.class org.apache.kafka.streams.tests.EosTestClient$2.class org.apache.kafka.streams.tests.SmokeTestDriver$NumberDeserializer.class org.apache.kafka.streams.tests.StreamsStandByReplicaTest.class org.apache.kafka.streams.tests.EosTestClient$6.class org.apache.kafka.streams.tests.SmokeTestUtil$Agg$3.class org.apache.kafka.streams.tests.ShutdownDeadlockTest$1.class org.apache.kafka.streams.tests.SmokeTestDriver$ValueList.class org.apache.kafka.streams.tests.SmokeTestDriver$VerificationResult.class org.apache.kafka.streams.tests.EosTestClient$5.class org.apache.kafka.streams.tests.StreamsUpgradeTest$FutureStreamsPartitionAssignor.class org.apache.kafka.streams.tests.StreamsEosTest.class org.apache.kafka.streams.tests.EosTestClient$4.class org.apache.kafka.streams.tests.StreamsOptimizedTest.class org.apache.kafka.streams.tests.ShutdownDeadlockTest.class org.apache.kafka.streams.tests.SmokeTestDriver.class org.apache.kafka.streams.tests.SmokeTestUtil.class org.apache.kafka.streams.tests.EosTestClient.class org.apache.kafka.streams.tests.EosTestClient$3.class org.apache.kafka.streams.tests.SmokeTestUtil$Unwindow.class org.apache.kafka.streams.tests.ShutdownDeadlockTest$2.class org.apache.kafka.streams.tests.EosTestClient$9.class org.apache.kafka.streams.tests.SystemTestUtilTest.class org.apache.kafka.streams.tests.StreamsUpgradeTest.class org.apache.kafka.streams.tests.StreamsSmokeTest.class org.apache.kafka.streams.tests.StreamsUpgradeTest$FutureSubscriptionInfo.class org.apache.kafka.streams.tests.StreamsUpgradeTest$FutureAssignmentInfo.class org.apache.kafka.streams.tests.EosTestClient$8.class org.apache.kafka.streams.tests.StreamsBrokerDownResilienceTest$2.class org.apache.kafka.streams.tests.SmokeTestUtil$Agg$2.class org.apache.kafka.streams.tests.SmokeTestUtil$Agg$4.class org.apache.kafka.streams.tests.StreamsBrokerDownResilienceTest$3.class org.apache.kafka.streams.tests.SmokeTestUtil$Agg$1.class org.apache.kafka.streams.tests.SmokeTestUtil$Agg.class org.apache.kafka.streams.tests.SmokeTestClient.class org.apache.kafka.streams.tests.EosTestClient$1.class org.apache.kafka.streams.tests.SystemTestUtil.class org.apache.kafka.streams.tests.StreamsNamedRepartitionTest.class org.apache.kafka.streams.tests.ShutdownDeadlockTest$3.class org.apache.kafka.streams.tests.StreamsOptimizedTest$1.class org.apache.kafka.streams.tests.BrokerCompatibilityTest$2.class org.apache.kafka.streams.tests.StreamsBrokerDownResilienceTest.class org.apache.kafka.streams.tests.StreamsBrokerDownResilienceTest$1.class org.apache.kafka.streams.tests.BrokerCompatibilityTest.class org.apache.kafka.streams.tests.EosTestClient$7.class org.apache.kafka.streams.tests.SmokeTestUtil$1$1.class org.apache.kafka.streams.tests.BrokerCompatibilityTest$1.class org.apache.kafka.streams.tests.SmokeTestUtil$1.class org.apache.kafka.streams.tests.StreamsUpgradeTest$FutureKafkaClientSupplier.class org.apache.kafka.streams.KafkaStreamsWrapper.class org.apache.kafka.streams.TopologyTest$LocalMockProcessorSupplier.class org.apache.kafka.streams.KafkaStreamsTest$2.class org.apache.kafka.streams.TopologyTest$LocalMockProcessorSupplier$1.class org.apache.kafka.streams.KeyValueTimestamp.class org.apache.kafka.streams.tools.StreamsResetterTest.class org.apache.kafka.streams.TopologyTest.class org.apache.kafka.streams.KafkaStreamsTest$StateListenerStub.class org.apache.kafka.streams.EqualityCheck.class org.apache.kafka.streams.TopologyTestDriverWrapper.class org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest.class org.apache.kafka.streams.processor.internals.ForwardingDisabledProcessorContextTest.class org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest$TestProcessorContext.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest$3.class org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest$1.class org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest.class org.apache.kafka.streams.processor.internals.assignment.ClientStateTest.class org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest.class org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest.class org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest$2.class org.apache.kafka.streams.processor.internals.GlobalProcessorContextImplTest.class org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest$2.class org.apache.kafka.streams.processor.internals.StreamThreadTest$2.class org.apache.kafka.streams.processor.internals.PunctuationQueueTest$3.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$2.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$7.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$4.class org.apache.kafka.streams.processor.internals.StateRestorerTest.class org.apache.kafka.streams.processor.internals.CopartitionedTopicsValidatorTest.class org.apache.kafka.streams.processor.internals.StateDirectoryTest$2.class org.apache.kafka.streams.processor.internals.ProcessorRecordContextTest.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$ConverterStore.class org.apache.kafka.streams.processor.internals.RecordQueueTest.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest$ConverterStore.class org.apache.kafka.streams.processor.internals.StateRestoreCallbackAdapterTest.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$10.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$8.class org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$3.class org.apache.kafka.streams.processor.internals.SingleGroupPartitionGrouperStub.class org.apache.kafka.streams.processor.internals.SinkNodeTest.class org.apache.kafka.streams.processor.internals.testutil.LogCaptureAppender.class org.apache.kafka.streams.processor.internals.testutil.LogCaptureAppender$Event.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$TimestampProcessor.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest$2.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$StatefulProcessor.class org.apache.kafka.streams.processor.internals.CompositeRestoreListenerTest$MockStateRestoreCallback.class org.apache.kafka.streams.processor.internals.ProcessorNodeTest$1.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$6.class org.apache.kafka.streams.processor.internals.StreamTaskTest$4.class org.apache.kafka.streams.processor.internals.StreamTaskTest$9.class org.apache.kafka.streams.processor.internals.PunctuationQueueTest$2.class org.apache.kafka.streams.processor.internals.AbstractTaskTest$4.class org.apache.kafka.streams.processor.internals.ProcessorNodeTest.class org.apache.kafka.streams.processor.internals.AbstractTaskTest.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest$1.class org.apache.kafka.streams.processor.internals.RecordDeserializerTest$TheSourceNode.class org.apache.kafka.streams.processor.internals.AbstractTaskTest$1.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$CustomTimestampExtractor.class org.apache.kafka.streams.processor.internals.InternalTopicManagerTest$2.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$7.class org.apache.kafka.streams.processor.internals.StateRestoreCallbackAdapterTest$1.class org.apache.kafka.streams.processor.internals.CompositeRestoreListenerTest$1.class org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest$1.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$MultiplexByNameProcessor.class org.apache.kafka.streams.processor.internals.QuickUnionTest.class org.apache.kafka.streams.processor.internals.ProcessorNodeTest$NoOpProcessor.class org.apache.kafka.streams.processor.internals.StreamTaskTest$7.class org.apache.kafka.streams.processor.internals.InternalTopicManagerTest$1.class org.apache.kafka.streams.processor.internals.InternalTopicManagerTest$4.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$8.class org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest$2.class org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest$2.class org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest$4.class org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest$1.class org.apache.kafka.streams.processor.internals.ProcessorNodeTest$ExceptionalProcessor.class org.apache.kafka.streams.processor.internals.StreamTaskTest$3.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$12.class org.apache.kafka.streams.processor.internals.SourceNodeTest$TheDeserializer.class org.apache.kafka.streams.processor.internals.StateDirectoryTest.class org.apache.kafka.streams.processor.internals.StreamTaskTest$5.class org.apache.kafka.streams.processor.internals.InternalTopicManagerTest$6.class org.apache.kafka.streams.processor.internals.PunctuationQueueTest$TestProcessor.class org.apache.kafka.streams.processor.internals.MockStreamsMetrics.class org.apache.kafka.streams.processor.internals.StandbyTaskTest.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$11.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$AddHeaderProcessor.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest$6.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest$8.class org.apache.kafka.streams.processor.internals.StreamThreadTest$1.class org.apache.kafka.streams.processor.internals.PunctuationQueueTest$4.class org.apache.kafka.streams.processor.internals.StreamTaskTest$11.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$4.class org.apache.kafka.streams.processor.internals.StreamThreadTest.class org.apache.kafka.streams.processor.internals.ProcessorTopologyFactories.class org.apache.kafka.streams.processor.internals.ProcessorContextImplTest.class org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$6.class org.apache.kafka.streams.processor.internals.InternalTopicConfigTest.class org.apache.kafka.streams.processor.internals.StreamTaskTest$6.class org.apache.kafka.streams.processor.internals.RecordDeserializerTest.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$9.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$13.class org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest$3.class org.apache.kafka.streams.processor.internals.PartitionGroupTest.class org.apache.kafka.streams.processor.internals.StreamTaskTest$12.class org.apache.kafka.streams.processor.internals.TaskManagerTest.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$1.class org.apache.kafka.streams.processor.internals.AssignedStreamsTasksTest.class org.apache.kafka.streams.processor.internals.CompositeRestoreListenerTest$MockNoListenBatchingStateRestoreCallback.class org.apache.kafka.streams.processor.internals.PunctuationQueueTest.class org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest$3.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$CustomStringSerializer.class org.apache.kafka.streams.processor.internals.StreamTaskTest$2.class org.apache.kafka.streams.processor.internals.StoreChangelogReaderTest.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$14.class org.apache.kafka.streams.processor.internals.ProcessorContextTest.class org.apache.kafka.streams.processor.internals.StreamTaskTest.class org.apache.kafka.streams.processor.internals.metrics.StreamsMetricsImplTest.class org.apache.kafka.streams.processor.internals.StreamTaskTest$10.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest$4.class org.apache.kafka.streams.processor.internals.StreamTaskTest$1.class org.apache.kafka.streams.processor.internals.AbstractTaskTest$3.class org.apache.kafka.streams.processor.internals.InternalTopicManagerTest.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$5.class org.apache.kafka.streams.processor.internals.SourceNodeTest.class org.apache.kafka.streams.processor.internals.CompositeRestoreListenerTest.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$MultiplexingProcessor.class org.apache.kafka.streams.processor.internals.StateConsumerTest.class org.apache.kafka.streams.processor.internals.ProcessorContextImplTest$1.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$3.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$TheStateRestoreCallback.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest$7.class org.apache.kafka.streams.processor.internals.AbstractTaskTest$2.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$FanOutTimestampProcessor.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest$5.class org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest.class org.apache.kafka.streams.processor.internals.StateConsumerTest$StateMaintainerStub.class org.apache.kafka.streams.processor.internals.InternalTopicManagerTest$5.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$15.class org.apache.kafka.streams.processor.internals.StreamTaskTest$8.class org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest$1.class org.apache.kafka.streams.processor.internals.StreamThreadTest$StateListenerStub.class org.apache.kafka.streams.processor.internals.InternalTopicManagerTest$3.class org.apache.kafka.streams.processor.internals.StateManagerStub.class org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest$1.class org.apache.kafka.streams.processor.internals.RecordCollectorTest.class org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$ValueTimestampProcessor.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$5.class org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$ForwardingProcessor.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$1.class org.apache.kafka.streams.processor.internals.PunctuationQueueTest$1.class org.apache.kafka.streams.processor.internals.StateDirectoryTest$1.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$9.class org.apache.kafka.streams.processor.internals.GlobalStateTaskTest.class org.apache.kafka.streams.processor.internals.TimestampedKeyValueStoreMaterializerTest.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$2.class org.apache.kafka.streams.processor.internals.StandbyTaskTest$1.class org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest$10.class org.apache.kafka.streams.processor.internals.MockChangelogReader.class org.apache.kafka.streams.processor.WallclockTimestampExtractorTest.class org.apache.kafka.streams.processor.TimestampExtractorTest.class org.apache.kafka.streams.processor.DefaultPartitionGrouperTest.class org.apache.kafka.streams.processor.WallclockTimestampExtractorTest$InBetween.class org.apache.kafka.streams.processor.FailOnInvalidTimestampTest.class org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestampTest.class org.apache.kafka.streams.KafkaStreamsTest.class org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest$1.class org.apache.kafka.streams.integration.RegexSourceIntegrationTest$1.class org.apache.kafka.streams.integration.EosIntegrationTest$1.class org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.class org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest$1.class org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest$Driver.class org.apache.kafka.streams.integration.ResetIntegrationTest.class org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest$1.class org.apache.kafka.streams.integration.ResetIntegrationWithSslTest.class org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest$MetadataValidator$1.class org.apache.kafka.streams.integration.RestoreIntegrationTest$1.class org.apache.kafka.streams.integration.InternalTopicIntegrationTest.class org.apache.kafka.streams.integration.RegexSourceIntegrationTest$4.class #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	无