登录注册

Jar文件详情内容

kafka-streams-0.10.1.0-test.jar

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

组织ID:	org.apache.kafka
项目ID:	kafka-streams
版本:	0.10.1.0
最后修改时间:	2020-03-04 09:22:14
包类型:	jar
大小:	559.59KB

Maven引入代码:	`<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> <version>0.10.1.0</version> </dependency>`
Gradle引入代码:	`org.apache.kafka:kafka-streams:0.10.1.0`
下载Jar包:	kafka-streams-0.10.1.0-test.jar
Jar包内容:	展开复制 META-INF/MANIFEST.MF LICENSE NOTICE org.apache.kafka.streams.integration.FanoutIntegrationTest$1.class org.apache.kafka.streams.integration.FanoutIntegrationTest$2.class org.apache.kafka.streams.integration.FanoutIntegrationTest.class org.apache.kafka.streams.integration.InternalTopicIntegrationTest$1.class org.apache.kafka.streams.integration.InternalTopicIntegrationTest$2.class org.apache.kafka.streams.integration.InternalTopicIntegrationTest.class org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest$1.class org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest$2.class org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest$3.class org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest$4.class org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$1.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$10.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$11.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$12.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$2.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$3.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$4.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$5.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$6.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$7.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$8.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest$9.class org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest.class org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest$1.class org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest$2.class org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest$3.class org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest$RegionWithClicks.class org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest.class org.apache.kafka.streams.integration.KStreamRepartitionJoinTest$1.class org.apache.kafka.streams.integration.KStreamRepartitionJoinTest$2.class org.apache.kafka.streams.integration.KStreamRepartitionJoinTest$3.class org.apache.kafka.streams.integration.KStreamRepartitionJoinTest$4.class org.apache.kafka.streams.integration.KStreamRepartitionJoinTest$5.class org.apache.kafka.streams.integration.KStreamRepartitionJoinTest$ExpectedOutputOnTopic.class org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.class org.apache.kafka.streams.integration.QueryableStateIntegrationTest$1.class org.apache.kafka.streams.integration.QueryableStateIntegrationTest$2.class org.apache.kafka.streams.integration.QueryableStateIntegrationTest$3.class org.apache.kafka.streams.integration.QueryableStateIntegrationTest$4.class org.apache.kafka.streams.integration.QueryableStateIntegrationTest$5.class org.apache.kafka.streams.integration.QueryableStateIntegrationTest$6.class org.apache.kafka.streams.integration.QueryableStateIntegrationTest$7.class org.apache.kafka.streams.integration.QueryableStateIntegrationTest$8.class org.apache.kafka.streams.integration.QueryableStateIntegrationTest$ProducerRunnable.class org.apache.kafka.streams.integration.QueryableStateIntegrationTest$StreamRunnable.class org.apache.kafka.streams.integration.QueryableStateIntegrationTest.class org.apache.kafka.streams.integration.RegexSourceIntegrationTest$1.class org.apache.kafka.streams.integration.RegexSourceIntegrationTest$2.class org.apache.kafka.streams.integration.RegexSourceIntegrationTest$3.class org.apache.kafka.streams.integration.RegexSourceIntegrationTest$4.class org.apache.kafka.streams.integration.RegexSourceIntegrationTest$5.class org.apache.kafka.streams.integration.RegexSourceIntegrationTest$6.class org.apache.kafka.streams.integration.RegexSourceIntegrationTest$TestStreamThread.class org.apache.kafka.streams.integration.RegexSourceIntegrationTest.class org.apache.kafka.streams.integration.ResetIntegrationTest$1.class org.apache.kafka.streams.integration.ResetIntegrationTest$2.class org.apache.kafka.streams.integration.ResetIntegrationTest$3.class org.apache.kafka.streams.integration.ResetIntegrationTest$WaitUntilConsumerGroupGotClosed.class org.apache.kafka.streams.integration.ResetIntegrationTest.class org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster.class org.apache.kafka.streams.integration.utils.IntegrationTestUtils$1.class org.apache.kafka.streams.integration.utils.IntegrationTestUtils$2.class org.apache.kafka.streams.integration.utils.IntegrationTestUtils.class org.apache.kafka.streams.integration.utils.KafkaEmbedded.class org.apache.kafka.streams.KafkaStreamsTest$1.class org.apache.kafka.streams.KafkaStreamsTest.class org.apache.kafka.streams.KeyValueTest.class org.apache.kafka.streams.kstream.internals.KeyValuePrinterProcessorTest$1.class org.apache.kafka.streams.kstream.internals.KeyValuePrinterProcessorTest$MockDeserializer.class org.apache.kafka.streams.kstream.internals.KeyValuePrinterProcessorTest$MockObject.class org.apache.kafka.streams.kstream.internals.KeyValuePrinterProcessorTest$MockSerializer.class org.apache.kafka.streams.kstream.internals.KeyValuePrinterProcessorTest.class org.apache.kafka.streams.kstream.internals.KGroupedStreamImplTest.class org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest$1.class org.apache.kafka.streams.kstream.internals.KGroupedTableImplTest.class org.apache.kafka.streams.kstream.internals.KStreamBranchTest$1.class org.apache.kafka.streams.kstream.internals.KStreamBranchTest$2.class org.apache.kafka.streams.kstream.internals.KStreamBranchTest$3.class org.apache.kafka.streams.kstream.internals.KStreamBranchTest.class org.apache.kafka.streams.kstream.internals.KStreamFilterTest$1.class org.apache.kafka.streams.kstream.internals.KStreamFilterTest.class org.apache.kafka.streams.kstream.internals.KStreamFlatMapTest$1.class org.apache.kafka.streams.kstream.internals.KStreamFlatMapTest.class org.apache.kafka.streams.kstream.internals.KStreamFlatMapValuesTest$1.class org.apache.kafka.streams.kstream.internals.KStreamFlatMapValuesTest.class org.apache.kafka.streams.kstream.internals.KStreamForeachTest$1.class org.apache.kafka.streams.kstream.internals.KStreamForeachTest.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$1.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$10.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$2.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$3.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$4.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$5.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$6.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$7.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$8.class org.apache.kafka.streams.kstream.internals.KStreamImplTest$9.class org.apache.kafka.streams.kstream.internals.KStreamImplTest.class org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest.class org.apache.kafka.streams.kstream.internals.KStreamKStreamLeftJoinTest.class org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest.class org.apache.kafka.streams.kstream.internals.KStreamMapTest$1.class org.apache.kafka.streams.kstream.internals.KStreamMapTest.class org.apache.kafka.streams.kstream.internals.KStreamMapValuesTest$1.class org.apache.kafka.streams.kstream.internals.KStreamMapValuesTest.class org.apache.kafka.streams.kstream.internals.KStreamSelectKeyTest$1.class org.apache.kafka.streams.kstream.internals.KStreamSelectKeyTest.class org.apache.kafka.streams.kstream.internals.KStreamTransformTest$1$1.class org.apache.kafka.streams.kstream.internals.KStreamTransformTest$1.class org.apache.kafka.streams.kstream.internals.KStreamTransformTest.class org.apache.kafka.streams.kstream.internals.KStreamTransformValuesTest$1$1.class org.apache.kafka.streams.kstream.internals.KStreamTransformValuesTest$1.class org.apache.kafka.streams.kstream.internals.KStreamTransformValuesTest.class org.apache.kafka.streams.kstream.internals.KStreamWindowAggregateTest$1.class org.apache.kafka.streams.kstream.internals.KStreamWindowAggregateTest.class org.apache.kafka.streams.kstream.internals.KTableAggregateTest$1.class org.apache.kafka.streams.kstream.internals.KTableAggregateTest$2.class org.apache.kafka.streams.kstream.internals.KTableAggregateTest$3.class org.apache.kafka.streams.kstream.internals.KTableAggregateTest$4.class org.apache.kafka.streams.kstream.internals.KTableAggregateTest$5.class org.apache.kafka.streams.kstream.internals.KTableAggregateTest.class org.apache.kafka.streams.kstream.internals.KTableFilterTest$1.class org.apache.kafka.streams.kstream.internals.KTableFilterTest$2.class org.apache.kafka.streams.kstream.internals.KTableFilterTest$3.class org.apache.kafka.streams.kstream.internals.KTableFilterTest$4.class org.apache.kafka.streams.kstream.internals.KTableFilterTest$5.class org.apache.kafka.streams.kstream.internals.KTableFilterTest$6.class org.apache.kafka.streams.kstream.internals.KTableFilterTest$7.class org.apache.kafka.streams.kstream.internals.KTableFilterTest.class org.apache.kafka.streams.kstream.internals.KTableForeachTest$1.class org.apache.kafka.streams.kstream.internals.KTableForeachTest.class org.apache.kafka.streams.kstream.internals.KTableImplTest$1.class org.apache.kafka.streams.kstream.internals.KTableImplTest$2.class org.apache.kafka.streams.kstream.internals.KTableImplTest$3.class org.apache.kafka.streams.kstream.internals.KTableImplTest$4.class org.apache.kafka.streams.kstream.internals.KTableImplTest$5.class org.apache.kafka.streams.kstream.internals.KTableImplTest$6.class org.apache.kafka.streams.kstream.internals.KTableImplTest$7.class org.apache.kafka.streams.kstream.internals.KTableImplTest$8.class org.apache.kafka.streams.kstream.internals.KTableImplTest$9.class org.apache.kafka.streams.kstream.internals.KTableImplTest.class org.apache.kafka.streams.kstream.internals.KTableKTableJoinTest.class org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest.class org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoinTest.class org.apache.kafka.streams.kstream.internals.KTableMapKeysTest$1.class org.apache.kafka.streams.kstream.internals.KTableMapKeysTest.class org.apache.kafka.streams.kstream.internals.KTableMapValuesTest$1.class org.apache.kafka.streams.kstream.internals.KTableMapValuesTest$2.class org.apache.kafka.streams.kstream.internals.KTableMapValuesTest$3.class org.apache.kafka.streams.kstream.internals.KTableMapValuesTest$4.class org.apache.kafka.streams.kstream.internals.KTableMapValuesTest$5.class org.apache.kafka.streams.kstream.internals.KTableMapValuesTest.class org.apache.kafka.streams.kstream.internals.KTableSourceTest.class org.apache.kafka.streams.kstream.internals.WindowedStreamPartitionerTest.class org.apache.kafka.streams.kstream.JoinWindowsTest.class org.apache.kafka.streams.kstream.KStreamBuilderTest$1.class org.apache.kafka.streams.kstream.KStreamBuilderTest$2.class org.apache.kafka.streams.kstream.KStreamBuilderTest$3.class org.apache.kafka.streams.kstream.KStreamBuilderTest.class org.apache.kafka.streams.kstream.TimeWindowsTest.class org.apache.kafka.streams.kstream.UnlimitedWindowsTest.class org.apache.kafka.streams.perf.SimpleBenchmark$1.class org.apache.kafka.streams.perf.SimpleBenchmark$2.class org.apache.kafka.streams.perf.SimpleBenchmark$3.class org.apache.kafka.streams.perf.SimpleBenchmark$4.class org.apache.kafka.streams.perf.SimpleBenchmark$5$1.class org.apache.kafka.streams.perf.SimpleBenchmark$5.class org.apache.kafka.streams.perf.SimpleBenchmark$6$1.class org.apache.kafka.streams.perf.SimpleBenchmark$6.class org.apache.kafka.streams.perf.SimpleBenchmark$7$1.class org.apache.kafka.streams.perf.SimpleBenchmark$7.class org.apache.kafka.streams.perf.SimpleBenchmark$CountDownAction.class org.apache.kafka.streams.perf.SimpleBenchmark.class org.apache.kafka.streams.processor.DefaultPartitionGrouperTest.class org.apache.kafka.streams.processor.internals.AbstractTaskTest$1.class org.apache.kafka.streams.processor.internals.AbstractTaskTest$2.class org.apache.kafka.streams.processor.internals.AbstractTaskTest.class org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest.class org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest.class org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest.class org.apache.kafka.streams.processor.internals.InternalTopicConfigTest.class org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest.class org.apache.kafka.streams.processor.internals.PartitionGroupTest$1.class org.apache.kafka.streams.processor.internals.PartitionGroupTest.class org.apache.kafka.streams.processor.internals.ProcessorNodeTest$1.class org.apache.kafka.streams.processor.internals.ProcessorNodeTest$ExceptionalProcessor.class org.apache.kafka.streams.processor.internals.ProcessorNodeTest.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest$MockRestoreConsumer.class org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$1.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$2.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$CustomTimestampExtractor.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$ForwardingProcessor.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$MultiplexByNameProcessor.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$MultiplexingProcessor.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest$StatefulProcessor.class org.apache.kafka.streams.processor.internals.ProcessorTopologyTest.class org.apache.kafka.streams.processor.internals.PunctuationQueueTest$1.class org.apache.kafka.streams.processor.internals.PunctuationQueueTest$TestProcessor.class org.apache.kafka.streams.processor.internals.PunctuationQueueTest.class org.apache.kafka.streams.processor.internals.QuickUnionTest.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$1.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$2.class org.apache.kafka.streams.processor.internals.RecordCollectorTest$3.class org.apache.kafka.streams.processor.internals.RecordCollectorTest.class org.apache.kafka.streams.processor.internals.RecordContextStub.class org.apache.kafka.streams.processor.internals.RecordQueueTest.class org.apache.kafka.streams.processor.internals.StandbyTaskTest$1.class org.apache.kafka.streams.processor.internals.StandbyTaskTest$2.class org.apache.kafka.streams.processor.internals.StandbyTaskTest.class org.apache.kafka.streams.processor.internals.StateDirectoryTest.class org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest$1.class org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest$2.class org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest$MockInternalTopicManager.class org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest.class org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest$1.class org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest$2.class org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest$3.class org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest$4.class org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest.class org.apache.kafka.streams.processor.internals.StreamTaskTest$1.class org.apache.kafka.streams.processor.internals.StreamTaskTest$2.class org.apache.kafka.streams.processor.internals.StreamTaskTest$3.class org.apache.kafka.streams.processor.internals.StreamTaskTest$4.class org.apache.kafka.streams.processor.internals.StreamTaskTest.class org.apache.kafka.streams.processor.internals.StreamThreadTest$1.class org.apache.kafka.streams.processor.internals.StreamThreadTest$2.class org.apache.kafka.streams.processor.internals.StreamThreadTest$3.class org.apache.kafka.streams.processor.internals.StreamThreadTest$4.class org.apache.kafka.streams.processor.internals.StreamThreadTest$TestStreamTask.class org.apache.kafka.streams.processor.internals.StreamThreadTest.class org.apache.kafka.streams.processor.TopologyBuilderTest$1.class org.apache.kafka.streams.processor.TopologyBuilderTest.class org.apache.kafka.streams.smoketest.SmokeTestClient$1.class org.apache.kafka.streams.smoketest.SmokeTestClient$10.class org.apache.kafka.streams.smoketest.SmokeTestClient$11.class org.apache.kafka.streams.smoketest.SmokeTestClient$12.class org.apache.kafka.streams.smoketest.SmokeTestClient$2.class org.apache.kafka.streams.smoketest.SmokeTestClient$3.class org.apache.kafka.streams.smoketest.SmokeTestClient$4.class org.apache.kafka.streams.smoketest.SmokeTestClient$5.class org.apache.kafka.streams.smoketest.SmokeTestClient$6.class org.apache.kafka.streams.smoketest.SmokeTestClient$7.class org.apache.kafka.streams.smoketest.SmokeTestClient$8.class org.apache.kafka.streams.smoketest.SmokeTestClient$9.class org.apache.kafka.streams.smoketest.SmokeTestClient.class org.apache.kafka.streams.smoketest.SmokeTestDriver$1.class org.apache.kafka.streams.smoketest.SmokeTestDriver$ValueList.class org.apache.kafka.streams.smoketest.SmokeTestDriver.class org.apache.kafka.streams.smoketest.SmokeTestUtil$1$1.class org.apache.kafka.streams.smoketest.SmokeTestUtil$1.class org.apache.kafka.streams.smoketest.SmokeTestUtil$Agg$1.class org.apache.kafka.streams.smoketest.SmokeTestUtil$Agg$2.class org.apache.kafka.streams.smoketest.SmokeTestUtil$Agg$3.class org.apache.kafka.streams.smoketest.SmokeTestUtil$Agg$4.class org.apache.kafka.streams.smoketest.SmokeTestUtil$Agg.class org.apache.kafka.streams.smoketest.SmokeTestUtil$Unwindow.class org.apache.kafka.streams.smoketest.SmokeTestUtil.class org.apache.kafka.streams.smoketest.StreamsSmokeTest$1.class org.apache.kafka.streams.smoketest.StreamsSmokeTest.class org.apache.kafka.streams.smoketest.TestTimestampExtractor.class org.apache.kafka.streams.state.internals.AbstractKeyValueStoreTest.class org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest$CacheFlushListenerStub.class org.apache.kafka.streams.state.internals.CachingKeyValueStoreTest.class org.apache.kafka.streams.state.internals.CachingWindowStoreTest.class org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest$1.class org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest.class org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest.class org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIteratorTest.class org.apache.kafka.streams.state.internals.DelegatingPeekingWindowIteratorTest.class org.apache.kafka.streams.state.internals.InMemoryKeyValueStore$TheIterator.class org.apache.kafka.streams.state.internals.InMemoryKeyValueStore.class org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreTest.class org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest.class org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueStoreIteratorTest.class org.apache.kafka.streams.state.internals.MergedSortedCacheWindowStoreIteratorTest$WindowStoreIteratorStub.class org.apache.kafka.streams.state.internals.MergedSortedCacheWindowStoreIteratorTest.class org.apache.kafka.streams.state.internals.NamedCacheTest$1.class org.apache.kafka.streams.state.internals.NamedCacheTest.class org.apache.kafka.streams.state.internals.OffsetCheckpointTest.class org.apache.kafka.streams.state.internals.QueryableStoreProviderTest.class org.apache.kafka.streams.state.internals.ReadOnlyWindowStoreStub$TheWindowStoreIterator.class org.apache.kafka.streams.state.internals.ReadOnlyWindowStoreStub.class org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreTest$TheRocksDbConfigSetter.class #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	无