登录注册

Jar文件详情内容

kafka-streams-2.1.1.jar

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

组织ID:	org.apache.kafka
项目ID:	kafka-streams
版本:	2.1.1
最后修改时间:	2019-02-18 09:57:34
包类型:	jar
标题:	Apache Kafka
相关URL:	http://kafka.apache.org
大小:	851.38KB

Maven引入代码:	`<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> <version>2.1.1</version> </dependency>`
Gradle引入代码:	`org.apache.kafka:kafka-streams:2.1.1`
下载Jar包:	kafka-streams-2.1.1.jar
POM文件内容:	展开复制 <?xml version="1.0" encoding="UTF-8"?> <project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> <modelVersion>4.0.0</modelVersion> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> <version>2.1.1</version> <name>Apache Kafka</name> <url>http://kafka.apache.org</url> <licenses> <license> <name>The Apache Software License, Version 2.0</name> <url>http://www.apache.org/licenses/LICENSE-2.0.txt</url> <distribution>repo</distribution> </license> </licenses> <dependencies> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.1.1</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>connect-json</artifactId> <version>2.1.1</version> <scope>compile</scope> <exclusions> <exclusion> <artifactId>javax.ws.rs-api</artifactId> <groupId>*</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>1.7.25</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.rocksdb</groupId> <artifactId>rocksdbjni</artifactId> <version>5.14.2</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.11</artifactId> <version>2.1.1</version> <scope>test</scope> </dependency> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> <version>1.2.17</version> <scope>test</scope> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.12</version> <scope>test</scope> </dependency> <dependency> <groupId>org.easymock</groupId> <artifactId>easymock</artifactId> <version>4.0.1</version> <scope>test</scope> </dependency> <dependency> <groupId>org.bouncycastle</groupId> <artifactId>bcpkix-jdk15on</artifactId> <version>1.60</version> <scope>test</scope> </dependency> <dependency> <groupId>org.hamcrest</groupId> <artifactId>hamcrest-all</artifactId> <version>1.3</version> <scope>test</scope> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.25</version> <scope>test</scope> </dependency> </dependencies> </project>
Jar包内容:	展开复制 META-INF/MANIFEST.MF org.apache.kafka.streams.KafkaStreams$State.class org.apache.kafka.streams.Topology$AutoOffsetReset.class org.apache.kafka.streams.KafkaStreams$StateListener.class org.apache.kafka.streams.TopologyDescription.class org.apache.kafka.streams.Topology.class org.apache.kafka.streams.errors.ProductionExceptionHandler.class org.apache.kafka.streams.errors.LockException.class org.apache.kafka.streams.errors.ProductionExceptionHandler$ProductionExceptionHandlerResponse.class org.apache.kafka.streams.errors.DeserializationExceptionHandler.class org.apache.kafka.streams.errors.TaskAssignmentException.class org.apache.kafka.streams.errors.TaskMigratedException.class org.apache.kafka.streams.errors.DefaultProductionExceptionHandler.class org.apache.kafka.streams.errors.BrokerNotFoundException.class org.apache.kafka.streams.errors.LogAndContinueExceptionHandler.class org.apache.kafka.streams.errors.StreamsException.class org.apache.kafka.streams.errors.ProcessorStateException.class org.apache.kafka.streams.errors.DeserializationExceptionHandler$DeserializationHandlerResponse.class org.apache.kafka.streams.errors.LogAndFailExceptionHandler.class org.apache.kafka.streams.errors.TaskIdFormatException.class org.apache.kafka.streams.errors.InvalidStateStoreException.class org.apache.kafka.streams.errors.TopologyException.class org.apache.kafka.streams.internals.ApiUtils.class org.apache.kafka.streams.KafkaStreams$3.class org.apache.kafka.streams.KafkaStreams$1.class org.apache.kafka.streams.state.QueryableStoreTypes$SessionStoreType.class org.apache.kafka.streams.state.StoreBuilder.class org.apache.kafka.streams.state.HostInfo.class org.apache.kafka.streams.state.Stores$2.class org.apache.kafka.streams.state.StateSerdes.class org.apache.kafka.streams.state.SessionBytesStoreSupplier.class org.apache.kafka.streams.state.SessionStore.class org.apache.kafka.streams.state.ReadOnlySessionStore.class org.apache.kafka.streams.state.Stores$1.class org.apache.kafka.streams.state.ReadOnlyWindowStore.class org.apache.kafka.streams.state.internals.ThreadCache$MemoryLRUCacheBytesIterator.class org.apache.kafka.streams.state.internals.CachingKeyValueStore.class org.apache.kafka.streams.state.internals.Segments.class org.apache.kafka.streams.state.internals.OffsetCheckpoint.class org.apache.kafka.streams.state.internals.AbstractMergedSortedCacheStoreIterator.class org.apache.kafka.streams.state.internals.CachingSessionStore$1.class org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore$1.class org.apache.kafka.streams.state.internals.MeteredKeyValueStore$1.class org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStore.class org.apache.kafka.streams.state.internals.NamedCache$NamedCacheMetrics.class org.apache.kafka.streams.state.internals.Segment.class org.apache.kafka.streams.state.internals.KeyValueIterators.class org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStore.class org.apache.kafka.streams.state.internals.QueryableStoreProvider.class org.apache.kafka.streams.state.internals.OrderedBytes.class org.apache.kafka.streams.state.internals.InMemoryTimeOrderedKeyValueBuffer.class org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIterator.class org.apache.kafka.streams.state.internals.SegmentedBytesStore.class org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore.class org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStore.class org.apache.kafka.streams.state.internals.AbstractStoreBuilder.class org.apache.kafka.streams.state.internals.CacheFunction.class org.apache.kafka.streams.state.internals.WrappingStoreProvider.class org.apache.kafka.streams.state.internals.InMemoryKeyValueStore.class org.apache.kafka.streams.state.internals.StoreChangeLogger.class org.apache.kafka.streams.state.internals.KeyValueIterators$1.class org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueBytesStoreIterator.class org.apache.kafka.streams.state.internals.CachingSessionStore.class org.apache.kafka.streams.state.internals.StreamThreadStateStoreProvider.class org.apache.kafka.streams.state.internals.SessionKeySchema.class org.apache.kafka.streams.state.internals.LRUCacheEntry.class org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStore$2.class org.apache.kafka.streams.state.internals.WindowStoreIteratorWrapper$WrappedKeyValueIterator.class org.apache.kafka.streams.state.internals.RocksDBStore$RocksDbIterator.class org.apache.kafka.streams.state.internals.CachingWindowStore$1.class org.apache.kafka.streams.state.internals.KeyValueStoreBuilder.class org.apache.kafka.streams.state.internals.WrappedSessionStoreIterator.class org.apache.kafka.streams.state.internals.InMemoryTimeOrderedKeyValueBuffer$BufferKey.class org.apache.kafka.streams.state.internals.NamedCache$LRUNode.class org.apache.kafka.streams.state.internals.NamedCache$1.class org.apache.kafka.streams.state.internals.ContextualRecord.class org.apache.kafka.streams.state.internals.RocksDBStore$RocksDBBatchingRestoreCallback.class org.apache.kafka.streams.state.internals.RocksDBStore$RocksDBRangeIterator.class org.apache.kafka.streams.state.internals.SegmentedCacheFunction.class org.apache.kafka.streams.state.internals.MemoryNavigableLRUCache.class org.apache.kafka.streams.state.internals.MeteredKeyValueStore$Action.class org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore$2.class org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStore$1.class org.apache.kafka.streams.state.internals.PeekingKeyValueIterator.class org.apache.kafka.streams.state.internals.MeteredWindowStore.class org.apache.kafka.streams.state.internals.RocksDbSessionBytesStoreSupplier.class org.apache.kafka.streams.state.internals.CachedStateStore.class org.apache.kafka.streams.state.internals.RocksDBWindowStore.class org.apache.kafka.streams.state.internals.MeteredWindowedKeyValueIterator.class org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStore$1.class org.apache.kafka.streams.state.internals.KeyValueIterators$EmptyKeyValueIterator.class org.apache.kafka.streams.state.internals.SegmentedBytesStore$KeySchema.class org.apache.kafka.streams.state.internals.SessionKeySchema$1.class org.apache.kafka.streams.state.internals.GlobalStateStoreProvider.class org.apache.kafka.streams.state.internals.FilteredCacheIterator.class org.apache.kafka.streams.state.internals.StateStoreProvider.class org.apache.kafka.streams.state.internals.ThreadCache.class org.apache.kafka.streams.state.internals.MemoryLRUCache.class org.apache.kafka.streams.state.internals.ThreadCache$DirtyEntryFlushListener.class org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIterator.class org.apache.kafka.streams.state.internals.TimeOrderedKeyValueBuffer.class org.apache.kafka.streams.state.internals.MemoryLRUCache$EldestEntryRemovalListener.class org.apache.kafka.streams.state.internals.NextIteratorFunction.class org.apache.kafka.streams.state.internals.InMemoryKeyValueStore$InMemoryKeyValueIterator.class org.apache.kafka.streams.state.internals.RocksDBStore.class org.apache.kafka.streams.state.internals.metrics.Sensors.class org.apache.kafka.streams.state.internals.InMemoryTimeOrderedKeyValueBuffer$1.class org.apache.kafka.streams.state.internals.FilteredCacheIterator$1.class org.apache.kafka.streams.state.internals.MergedSortedCacheWindowStoreIterator.class org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStore$1.class org.apache.kafka.streams.state.internals.MemoryLRUCache$1.class org.apache.kafka.streams.state.internals.WindowStoreBuilder.class org.apache.kafka.streams.state.internals.MemoryNavigableLRUCache$CacheIterator.class org.apache.kafka.streams.state.internals.CachingWindowStore.class org.apache.kafka.streams.state.internals.SegmentIterator.class org.apache.kafka.streams.state.internals.InMemoryTimeOrderedKeyValueBuffer$Builder.class org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStore.class org.apache.kafka.streams.state.internals.HasNextCondition.class org.apache.kafka.streams.state.internals.MergedSortedCacheWindowStoreKeyValueIterator.class org.apache.kafka.streams.state.internals.ChangeLoggingWindowBytesStore.class org.apache.kafka.streams.state.internals.NamedCache.class org.apache.kafka.streams.state.internals.WindowKeySchema.class org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.class org.apache.kafka.streams.state.internals.InMemoryKeyValueStore$1.class org.apache.kafka.streams.state.internals.MeteredKeyValueStore.class org.apache.kafka.streams.state.internals.MeteredWindowStoreIterator.class org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStore$1.class org.apache.kafka.streams.state.internals.SessionStoreBuilder.class org.apache.kafka.streams.state.internals.MeteredSessionStore.class org.apache.kafka.streams.state.internals.KeyValueIterators$EmptyWindowStoreIterator.class org.apache.kafka.streams.state.internals.WrappedStateStore$AbstractStateStore.class org.apache.kafka.streams.state.internals.WindowStoreIteratorWrapper$WrappedWindowStoreIterator.class org.apache.kafka.streams.state.internals.MemoryLRUCache$2.class org.apache.kafka.streams.state.internals.ChangeLoggingSessionBytesStore.class org.apache.kafka.streams.state.internals.RocksDBSessionStore.class org.apache.kafka.streams.state.internals.WrappedStateStore.class org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore$1.class org.apache.kafka.streams.state.internals.MeteredKeyValueStore$MeteredKeyValueIterator.class org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStore$3.class org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStore$RocksDBSegmentsBatchingRestoreCallback.class org.apache.kafka.streams.state.internals.ThreadCache$DirtyEntry.class org.apache.kafka.streams.state.internals.RocksDbKeyValueBytesStoreSupplier.class org.apache.kafka.streams.state.internals.WindowStoreIteratorWrapper.class org.apache.kafka.streams.state.internals.CachingKeyValueStore$1.class org.apache.kafka.streams.state.internals.RocksDbWindowBytesStoreSupplier.class org.apache.kafka.streams.state.internals.CompositeKeyValueIterator.class org.apache.kafka.streams.state.internals.WindowKeySchema$1.class org.apache.kafka.streams.state.Stores.class org.apache.kafka.streams.state.QueryableStoreTypes.class org.apache.kafka.streams.state.QueryableStoreTypes$WindowStoreType.class org.apache.kafka.streams.state.KeyValueIterator.class org.apache.kafka.streams.state.StreamsMetadata.class org.apache.kafka.streams.state.QueryableStoreTypes$QueryableStoreTypeMatcher.class org.apache.kafka.streams.state.WindowStoreIterator.class org.apache.kafka.streams.state.KeyValueStore.class org.apache.kafka.streams.state.KeyValueBytesStoreSupplier.class org.apache.kafka.streams.state.QueryableStoreType.class org.apache.kafka.streams.state.RocksDBConfigSetter.class org.apache.kafka.streams.state.ReadOnlyKeyValueStore.class org.apache.kafka.streams.state.StoreSupplier.class org.apache.kafka.streams.state.WindowBytesStoreSupplier.class org.apache.kafka.streams.state.QueryableStoreTypes$KeyValueStoreType.class org.apache.kafka.streams.state.WindowStore.class org.apache.kafka.streams.TopologyDescription$Processor.class org.apache.kafka.streams.KafkaStreams$StreamStateListener.class org.apache.kafka.streams.StreamsBuilder.class org.apache.kafka.streams.StreamsConfig$InternalConfig.class org.apache.kafka.streams.KafkaClientSupplier.class org.apache.kafka.streams.TopologyDescription$Node.class org.apache.kafka.streams.kstream.GlobalKTable.class org.apache.kafka.streams.kstream.Grouped.class org.apache.kafka.streams.kstream.Produced.class org.apache.kafka.streams.kstream.KeyValueMapper.class org.apache.kafka.streams.kstream.Aggregator.class org.apache.kafka.streams.kstream.Suppressed$BufferConfig.class org.apache.kafka.streams.kstream.JoinWindows.class org.apache.kafka.streams.kstream.Serialized.class org.apache.kafka.streams.kstream.Printed.class org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinValueGetter.class org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger.class org.apache.kafka.streams.kstream.internals.KStreamPeek.class org.apache.kafka.streams.kstream.internals.KStreamKStreamJoin$KStreamKStreamJoinProcessor.class org.apache.kafka.streams.kstream.internals.FullChangeSerde.class org.apache.kafka.streams.kstream.internals.KStreamImpl.class org.apache.kafka.streams.kstream.internals.SerializedInternal.class org.apache.kafka.streams.kstream.internals.KStreamBranch.class org.apache.kafka.streams.kstream.internals.KStreamJoinWindow$KStreamJoinWindowProcessor.class org.apache.kafka.streams.kstream.internals.KTableRepartitionMap$KTableMapProcessor.class org.apache.kafka.streams.kstream.internals.KStreamPeek$KStreamPeekProcessor.class org.apache.kafka.streams.kstream.internals.KStreamPrint.class org.apache.kafka.streams.kstream.internals.KStreamFlatMapValues$KStreamFlatMapValuesProcessor.class org.apache.kafka.streams.kstream.internals.WindowedStreamPartitioner.class org.apache.kafka.streams.kstream.internals.ProducedInternal.class org.apache.kafka.streams.kstream.internals.KStreamKStreamJoin$1.class org.apache.kafka.streams.kstream.internals.KStreamFlatMap$KStreamFlatMapProcessor.class org.apache.kafka.streams.kstream.internals.Change.class org.apache.kafka.streams.kstream.internals.ConsumedInternal.class org.apache.kafka.streams.kstream.internals.KStreamKTableJoinProcessor.class org.apache.kafka.streams.kstream.internals.KTableMapValues$1.class org.apache.kafka.streams.kstream.internals.KTableValueGetterSupplier.class org.apache.kafka.streams.kstream.internals.KTableTransformValues$KTableTransformValuesGetter.class org.apache.kafka.streams.kstream.internals.KStreamKTableJoin.class org.apache.kafka.streams.kstream.internals.AbstractStream$2.class org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoin$KTableKTableOuterJoinProcessor.class org.apache.kafka.streams.kstream.internals.KTableMaterializedValueGetterSupplier.class org.apache.kafka.streams.kstream.internals.FullChangeSerde$1.class org.apache.kafka.streams.kstream.internals.GroupedInternal.class org.apache.kafka.streams.kstream.internals.KStreamFilter.class org.apache.kafka.streams.kstream.internals.KTableSource$KTableSourceProcessor.class org.apache.kafka.streams.kstream.internals.KStreamAggregate.class org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinValueGetterSupplier.class org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoin.class org.apache.kafka.streams.kstream.internals.KTableMapValues.class org.apache.kafka.streams.kstream.internals.KStreamBranch$1.class org.apache.kafka.streams.kstream.internals.CacheFlushListener.class org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoin$1.class org.apache.kafka.streams.kstream.internals.AbstractStream$3.class org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinValueGetterSupplier.class org.apache.kafka.streams.kstream.internals.KeyValueStoreMaterializer.class org.apache.kafka.streams.kstream.internals.KStreamJoinWindow.class org.apache.kafka.streams.kstream.internals.KStreamFlatMap.class org.apache.kafka.streams.kstream.internals.KStreamWindowAggregate$KStreamWindowAggregateValueGetter.class org.apache.kafka.streams.kstream.internals.KTableReduce$1.class org.apache.kafka.streams.kstream.internals.KStreamAggregate$KStreamAggregateProcessor.class org.apache.kafka.streams.kstream.internals.KTableSourceValueGetterSupplier.class org.apache.kafka.streams.kstream.internals.WindowingDefaults.class org.apache.kafka.streams.kstream.internals.KStreamFlatMapValues$1.class org.apache.kafka.streams.kstream.internals.TupleForwarder.class org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregate.class org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$1.class org.apache.kafka.streams.kstream.internals.KStreamMap$1.class org.apache.kafka.streams.kstream.internals.ChangedSerializer.class org.apache.kafka.streams.kstream.internals.InternalStreamsBuilder.class org.apache.kafka.streams.kstream.internals.KStreamTransformValues$KStreamTransformValuesProcessor.class org.apache.kafka.streams.kstream.internals.KStreamWindowAggregate$KStreamWindowAggregateProcessor.class org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinValueGetter.class org.apache.kafka.streams.kstream.internals.KStreamPrint$1.class org.apache.kafka.streams.kstream.internals.KTableFilter$1.class org.apache.kafka.streams.kstream.internals.KTableTransformValues$1.class org.apache.kafka.streams.kstream.internals.SessionWindow.class org.apache.kafka.streams.kstream.internals.KStreamTransformValues.class org.apache.kafka.streams.kstream.internals.TimeWindow.class org.apache.kafka.streams.kstream.internals.KStreamPeek$1.class org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoin$KTableKTableInnerJoinValueGetterSupplier.class org.apache.kafka.streams.kstream.internals.KStreamGlobalKTableJoin.class org.apache.kafka.streams.kstream.internals.KTableFilter.class org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoin.class org.apache.kafka.streams.kstream.internals.KStreamPassThrough$KStreamPassThroughProcessor.class org.apache.kafka.streams.kstream.internals.GroupedStreamAggregateBuilder.class org.apache.kafka.streams.kstream.internals.KTableAggregate.class org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregate$1.class org.apache.kafka.streams.kstream.internals.KTableReduce.class org.apache.kafka.streams.kstream.internals.FullChangeSerde$2.class org.apache.kafka.streams.kstream.internals.GlobalKTableImpl.class org.apache.kafka.streams.kstream.internals.MaterializedInternal.class org.apache.kafka.streams.kstream.internals.KStreamFlatMapValues.class org.apache.kafka.streams.kstream.internals.KTableSourceValueGetterSupplier$1.class org.apache.kafka.streams.kstream.internals.KGroupedTableImpl.class org.apache.kafka.streams.kstream.internals.KStreamReduce.class org.apache.kafka.streams.kstream.internals.KStreamMapValues.class org.apache.kafka.streams.kstream.internals.KTableRepartitionMap.class org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoin$KTableKTableJoinProcessor.class org.apache.kafka.streams.kstream.internals.ForwardingCacheFlushListener.class org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoin$KTableKTableInnerJoinValueGetter.class org.apache.kafka.streams.kstream.internals.KStreamWindowAggregate.class org.apache.kafka.streams.kstream.internals.KStreamImpl$KStreamImplJoin.class org.apache.kafka.streams.kstream.internals.ChangedDeserializer.class org.apache.kafka.streams.kstream.internals.KStreamKStreamJoin.class org.apache.kafka.streams.kstream.internals.graph.OptimizableRepartitionNode$1.class org.apache.kafka.streams.kstream.internals.graph.StateStoreNode.class org.apache.kafka.streams.kstream.internals.graph.ProcessorGraphNode.class org.apache.kafka.streams.kstream.internals.graph.BaseJoinProcessorNode.class org.apache.kafka.streams.kstream.internals.graph.StatefulProcessorNode.class org.apache.kafka.streams.kstream.internals.graph.TableProcessorNode.class org.apache.kafka.streams.kstream.internals.graph.StreamsGraphNode.class org.apache.kafka.streams.kstream.internals.graph.OptimizableRepartitionNode$OptimizableRepartitionNodeBuilder.class org.apache.kafka.streams.kstream.internals.graph.KTableKTableJoinNode.class org.apache.kafka.streams.kstream.internals.graph.StreamStreamJoinNode$StreamStreamJoinNodeBuilder.class org.apache.kafka.streams.kstream.internals.graph.GroupedTableOperationRepartitionNode.class org.apache.kafka.streams.kstream.internals.graph.StreamStreamJoinNode.class org.apache.kafka.streams.kstream.internals.graph.KTableKTableJoinNode$1.class org.apache.kafka.streams.kstream.internals.graph.StreamSourceNode.class org.apache.kafka.streams.kstream.internals.graph.GroupedTableOperationRepartitionNode$1.class org.apache.kafka.streams.kstream.internals.graph.GraphGraceSearchUtil.class org.apache.kafka.streams.kstream.internals.graph.GlobalStoreNode.class org.apache.kafka.streams.kstream.internals.graph.KTableKTableJoinNode$KTableKTableJoinNodeBuilder.class org.apache.kafka.streams.kstream.internals.graph.BaseRepartitionNode.class org.apache.kafka.streams.kstream.internals.graph.StreamTableJoinNode.class org.apache.kafka.streams.kstream.internals.graph.TableSourceNode.class org.apache.kafka.streams.kstream.internals.graph.TableSourceNode$1.class org.apache.kafka.streams.kstream.internals.graph.ProcessorParameters.class org.apache.kafka.streams.kstream.internals.graph.GroupedTableOperationRepartitionNode$GroupedTableOperationRepartitionNodeBuilder.class org.apache.kafka.streams.kstream.internals.graph.StreamStreamJoinNode$1.class org.apache.kafka.streams.kstream.internals.graph.TableSourceNode$TableSourceNodeBuilder.class org.apache.kafka.streams.kstream.internals.graph.StreamSinkNode.class org.apache.kafka.streams.kstream.internals.graph.OptimizableRepartitionNode.class org.apache.kafka.streams.kstream.internals.KStreamMap.class org.apache.kafka.streams.kstream.internals.KStreamReduce$KStreamReduceProcessor.class org.apache.kafka.streams.kstream.internals.KStreamJoinWindow$1.class org.apache.kafka.streams.kstream.internals.KStreamPassThrough$1.class org.apache.kafka.streams.kstream.internals.PrintedInternal.class org.apache.kafka.streams.kstream.internals.InternalNameProvider.class org.apache.kafka.streams.kstream.internals.KStreamFlatMap$1.class org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoin$KTableKTableOuterJoinValueGetter.class org.apache.kafka.streams.kstream.internals.KTableReduce$KTableReduceProcessor.class org.apache.kafka.streams.kstream.internals.KStreamWindowAggregate$1.class org.apache.kafka.streams.kstream.internals.KStreamMapValues$KStreamMapProcessor.class org.apache.kafka.streams.kstream.internals.AbstractStream.class org.apache.kafka.streams.kstream.internals.KTableMapValues$KTableMapValuesProcessor.class org.apache.kafka.streams.kstream.internals.KStreamAggregate$KStreamAggregateValueGetter.class org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregate$KStreamSessionWindowAggregateProcessor.class org.apache.kafka.streams.kstream.internals.suppress.KTableSuppressProcessor.class org.apache.kafka.streams.kstream.internals.suppress.TimeDefinitions$WindowEndTimeDefinition.class org.apache.kafka.streams.kstream.internals.suppress.FinalResultsSuppressionBuilder.class org.apache.kafka.streams.kstream.internals.suppress.KTableSuppressProcessor$1.class org.apache.kafka.streams.kstream.internals.suppress.SuppressedInternal.class org.apache.kafka.streams.kstream.internals.suppress.TimeDefinitions$TimeDefinition.class org.apache.kafka.streams.kstream.internals.suppress.TimeDefinitions$TimeDefinitionType.class org.apache.kafka.streams.kstream.internals.suppress.EagerBufferConfigImpl.class org.apache.kafka.streams.kstream.internals.suppress.StrictBufferConfigImpl.class org.apache.kafka.streams.kstream.internals.suppress.BufferFullStrategy.class org.apache.kafka.streams.kstream.internals.suppress.TimeDefinitions$RecordTimeDefintion.class org.apache.kafka.streams.kstream.internals.suppress.BufferConfigInternal.class org.apache.kafka.streams.kstream.internals.suppress.TimeDefinitions.class org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.class org.apache.kafka.streams.kstream.internals.PrintForeachAction.class org.apache.kafka.streams.kstream.internals.InternalStreamsBuilder$1.class org.apache.kafka.streams.kstream.internals.UnlimitedWindow.class org.apache.kafka.streams.kstream.internals.KTableFilter$KTableFilterProcessor.class org.apache.kafka.streams.kstream.internals.KStreamFilter$1.class org.apache.kafka.streams.kstream.internals.KStreamMap$KStreamMapProcessor.class org.apache.kafka.streams.kstream.internals.WindowedSerializer.class org.apache.kafka.streams.kstream.internals.KTableRepartitionMap$1.class org.apache.kafka.streams.kstream.internals.KStreamWindowReduce.class org.apache.kafka.streams.kstream.internals.metrics.Sensors.class org.apache.kafka.streams.kstream.internals.KStreamReduce$KStreamReduceValueGetter.class org.apache.kafka.streams.kstream.internals.KTableAggregate$1.class org.apache.kafka.streams.kstream.internals.KStreamPassThrough.class org.apache.kafka.streams.kstream.internals.KTableProcessorSupplier.class org.apache.kafka.streams.kstream.internals.KStreamTransform$KStreamTransformProcessor.class org.apache.kafka.streams.kstream.internals.KTableSource.class org.apache.kafka.streams.kstream.internals.KStreamPrint$KStreamPrintProcessor.class org.apache.kafka.streams.kstream.internals.KTableKTableAbstractJoinValueGetterSupplier.class org.apache.kafka.streams.kstream.internals.KStreamTransform.class org.apache.kafka.streams.kstream.internals.KStreamAggregate$1.class org.apache.kafka.streams.kstream.internals.TimeWindowedKStreamImpl.class org.apache.kafka.streams.kstream.internals.KStreamBranch$KStreamBranchProcessor.class org.apache.kafka.streams.kstream.internals.KTableKTableAbstractJoin.class org.apache.kafka.streams.kstream.internals.FullTimeWindowedSerde.class org.apache.kafka.streams.kstream.internals.KTableImpl.class org.apache.kafka.streams.kstream.internals.AbstractStream$1.class org.apache.kafka.streams.kstream.internals.KStreamKTableJoin$1.class org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregate$KTableSessionWindowValueGetter.class org.apache.kafka.streams.kstream.internals.KTableMaterializedValueGetterSupplier$KTableMaterializedValueGetter.class org.apache.kafka.streams.kstream.internals.KStreamAggProcessorSupplier.class org.apache.kafka.streams.kstream.internals.KTableAggregate$KTableAggregateProcessor.class org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinProcessor.class org.apache.kafka.streams.kstream.internals.KStreamReduce$1.class org.apache.kafka.streams.kstream.internals.KTableMaterializedValueGetterSupplier$1.class org.apache.kafka.streams.kstream.internals.AbstractStream$3$1.class org.apache.kafka.streams.kstream.internals.KTableTransformValues$KTableTransformValuesProcessor.class org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin.class org.apache.kafka.streams.kstream.internals.KTableTransformValues.class org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin.class org.apache.kafka.streams.kstream.internals.KTableMapValues$KTableMapValuesValueGetter.class org.apache.kafka.streams.kstream.internals.KTableSourceValueGetterSupplier$KTableSourceValueGetter.class org.apache.kafka.streams.kstream.internals.KTableFilter$KTableFilterValueGetter.class org.apache.kafka.streams.kstream.internals.KStreamFilter$KStreamFilterProcessor.class org.apache.kafka.streams.kstream.internals.KGroupedStreamImpl.class org.apache.kafka.streams.kstream.internals.KTableSource$1.class org.apache.kafka.streams.kstream.internals.KTableValueGetter.class org.apache.kafka.streams.kstream.internals.KStreamMapValues$1.class org.apache.kafka.streams.kstream.internals.KTableRepartitionMap$KTableMapValueGetter.class org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$KTableKTableJoinMergeProcessor.class org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoin$KTableKTableOuterJoinValueGetterSupplier.class org.apache.kafka.streams.kstream.internals.SessionWindowedKStreamImpl.class org.apache.kafka.streams.kstream.Window.class org.apache.kafka.streams.kstream.SessionWindowedKStream.class org.apache.kafka.streams.kstream.Transformer.class org.apache.kafka.streams.kstream.TransformerSupplier.class org.apache.kafka.streams.kstream.Suppressed$StrictBufferConfig.class org.apache.kafka.streams.kstream.UnlimitedWindows.class org.apache.kafka.streams.kstream.Materialized.class org.apache.kafka.streams.kstream.ValueTransformer.class org.apache.kafka.streams.kstream.Windowed.class org.apache.kafka.streams.kstream.Printed$1.class org.apache.kafka.streams.kstream.Reducer.class org.apache.kafka.streams.kstream.ValueTransformerWithKey.class org.apache.kafka.streams.kstream.Consumed.class org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier.class org.apache.kafka.streams.kstream.SessionWindowedSerializer.class org.apache.kafka.streams.kstream.TimeWindowedSerializer.class org.apache.kafka.streams.kstream.SessionWindowedDeserializer.class org.apache.kafka.streams.kstream.ValueMapper.class org.apache.kafka.streams.kstream.TimeWindows.class org.apache.kafka.streams.kstream.ValueTransformerSupplier.class org.apache.kafka.streams.kstream.WindowedSerdes$SessionWindowedSerde.class org.apache.kafka.streams.kstream.Suppressed.class org.apache.kafka.streams.kstream.Windows.class org.apache.kafka.streams.kstream.WindowedSerdes$TimeWindowedSerde.class org.apache.kafka.streams.kstream.KStream.class org.apache.kafka.streams.kstream.ValueJoiner.class org.apache.kafka.streams.kstream.SessionWindows.class org.apache.kafka.streams.kstream.Predicate.class org.apache.kafka.streams.kstream.KGroupedTable.class org.apache.kafka.streams.kstream.WindowedSerdes.class org.apache.kafka.streams.kstream.KGroupedStream.class org.apache.kafka.streams.kstream.Merger.class org.apache.kafka.streams.kstream.ValueMapperWithKey.class org.apache.kafka.streams.kstream.KTable.class org.apache.kafka.streams.kstream.ForeachAction.class org.apache.kafka.streams.kstream.Joined.class org.apache.kafka.streams.kstream.TimeWindowedKStream.class org.apache.kafka.streams.kstream.TimeWindowedDeserializer.class org.apache.kafka.streams.kstream.Initializer.class org.apache.kafka.streams.StreamsConfig.class org.apache.kafka.streams.TopologyDescription$GlobalStore.class org.apache.kafka.streams.StreamsMetrics.class org.apache.kafka.streams.TopologyDescription$Source.class org.apache.kafka.streams.KafkaStreams$2.class org.apache.kafka.streams.KafkaStreams.class org.apache.kafka.streams.KafkaStreams$DelegatingStateRestoreListener.class org.apache.kafka.streams.TopologyDescription$Sink.class org.apache.kafka.streams.processor.BatchingStateRestoreCallback.class org.apache.kafka.streams.processor.TimestampExtractor.class org.apache.kafka.streams.processor.Punctuator.class org.apache.kafka.streams.processor.Processor.class org.apache.kafka.streams.processor.TaskMetadata.class org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestamp.class org.apache.kafka.streams.processor.AbstractNotifyingBatchingRestoreCallback.class org.apache.kafka.streams.processor.internals.assignment.AssignmentInfo.class org.apache.kafka.streams.processor.internals.assignment.TaskAssignor.class org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignor$TaskPairs.class org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignor$TaskPairs$Pair.class org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignor.class org.apache.kafka.streams.processor.internals.assignment.ClientState.class org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfo.class org.apache.kafka.streams.processor.internals.StateRestoreCallbackAdapter.class org.apache.kafka.streams.processor.internals.StandbyContextImpl$1.class org.apache.kafka.streams.processor.internals.AbstractTask.class org.apache.kafka.streams.processor.internals.InternalTopicManager.class org.apache.kafka.streams.processor.internals.StateDirectory$1.class org.apache.kafka.streams.processor.internals.AssignedStandbyTasks.class org.apache.kafka.streams.processor.internals.TaskManager.class org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$ProcessorNodeFactory.class org.apache.kafka.streams.processor.internals.StateRestorer.class org.apache.kafka.streams.processor.internals.ProcessorNodePunctuator.class org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$SourceNodeFactory.class org.apache.kafka.streams.processor.internals.DefaultStreamPartitioner.class org.apache.kafka.streams.processor.internals.StateDirectory.class org.apache.kafka.streams.processor.internals.GlobalStreamThread.class org.apache.kafka.streams.processor.internals.RepartitionTopicConfig.class org.apache.kafka.streams.processor.internals.StoreChangelogReader.class org.apache.kafka.streams.processor.internals.CompositeRestoreListener$NoOpStateRestoreListener.class org.apache.kafka.streams.processor.internals.StreamThread$StandbyTaskCreator.class org.apache.kafka.streams.processor.internals.StateManager.class org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$Subtopology.class org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$SubscriptionUpdates.class org.apache.kafka.streams.processor.internals.StreamsMetadataState$1.class org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$NodeFactory.class org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$1.class org.apache.kafka.streams.processor.internals.AbstractProcessorContext.class org.apache.kafka.streams.processor.internals.ProcessorNode.class org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$Source.class org.apache.kafka.streams.processor.internals.StreamTask.class org.apache.kafka.streams.processor.internals.StreamTask$1.class org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor$Error.class #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	kafka-clients-2.1.1.jar /org.apache.kafka/kafka-clients/2.1.1 查看kafka-clients所有版本文件 connect-json-2.1.1.jar /org.apache.kafka/connect-json/2.1.1 查看connect-json所有版本文件 slf4j-api-1.7.25.jar /org.slf4j/slf4j-api/1.7.25 查看slf4j-api所有版本文件 rocksdbjni-5.14.2.jar /org.rocksdb/rocksdbjni/5.14.2 查看rocksdbjni所有版本文件 kafka_2.11-2.1.1.jar /org.apache.kafka/kafka_2.11/2.1.1 查看kafka_2.11所有版本文件 log4j-1.2.17.jar /log4j/log4j/1.2.17 查看log4j所有版本文件 junit-4.12.jar /junit/junit/4.12 查看junit所有版本文件 easymock-4.0.1.jar /org.easymock/easymock/4.0.1 查看easymock所有版本文件 bcpkix-jdk15on-1.60.jar /org.bouncycastle/bcpkix-jdk15on/1.60 查看bcpkix-jdk15on所有版本文件 hamcrest-all-1.3.jar /org.hamcrest/hamcrest-all/1.3 查看hamcrest-all所有版本文件 slf4j-log4j12-1.7.25.jar /org.slf4j/slf4j-log4j12/1.7.25 查看slf4j-log4j12所有版本文件