组织ID: |
org.apache.kafka |
项目ID: |
kafka-streams |
版本: |
0.10.1.1 |
最后修改时间: |
2018-07-27 18:17:21 |
包类型: |
jar |
标题: |
Apache Kafka |
相关URL: |
http://kafka.apache.org |
大小: |
451.38KB |
|
Maven引入代码: |
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-streams</artifactId>
<version>0.10.1.1</version>
</dependency>
|
Gradle引入代码: |
org.apache.kafka:kafka-streams:0.10.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>0.10.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>0.10.1.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>connect-json</artifactId>
<version>0.10.1.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.21</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.rocksdb</groupId>
<artifactId>rocksdbjni</artifactId>
<version>4.9.0</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.9</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.6.3</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId>
<version>0.10.1.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.21</version>
<scope>test</scope>
</dependency>
</dependencies>
</project>
|
Jar包内容: |
META-INF/MANIFEST.MF
org.apache.kafka.streams.errors.InvalidStateStoreException.class
org.apache.kafka.streams.errors.ProcessorStateException.class
org.apache.kafka.streams.errors.StreamsException.class
org.apache.kafka.streams.errors.TaskAssignmentException.class
org.apache.kafka.streams.errors.TaskIdFormatException.class
org.apache.kafka.streams.errors.TopologyBuilderException.class
org.apache.kafka.streams.KafkaClientSupplier.class
org.apache.kafka.streams.KafkaStreams.class
org.apache.kafka.streams.KeyValue.class
org.apache.kafka.streams.kstream.Aggregator.class
org.apache.kafka.streams.kstream.ForeachAction.class
org.apache.kafka.streams.kstream.Initializer.class
org.apache.kafka.streams.kstream.internals.AbstractKTableKTableJoinValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.AbstractStream$1.class
org.apache.kafka.streams.kstream.internals.AbstractStream.class
org.apache.kafka.streams.kstream.internals.CacheFlushListener.class
org.apache.kafka.streams.kstream.internals.Change.class
org.apache.kafka.streams.kstream.internals.ChangedDeserializer.class
org.apache.kafka.streams.kstream.internals.ChangedSerializer.class
org.apache.kafka.streams.kstream.internals.ForwardingCacheFlushListener.class
org.apache.kafka.streams.kstream.internals.KeyValuePrinter$1.class
org.apache.kafka.streams.kstream.internals.KeyValuePrinter$KeyValuePrinterProcessor.class
org.apache.kafka.streams.kstream.internals.KeyValuePrinter.class
org.apache.kafka.streams.kstream.internals.KGroupedStreamImpl$1.class
org.apache.kafka.streams.kstream.internals.KGroupedStreamImpl$2.class
org.apache.kafka.streams.kstream.internals.KGroupedStreamImpl$3.class
org.apache.kafka.streams.kstream.internals.KGroupedStreamImpl$4.class
org.apache.kafka.streams.kstream.internals.KGroupedStreamImpl.class
org.apache.kafka.streams.kstream.internals.KGroupedTableImpl$1.class
org.apache.kafka.streams.kstream.internals.KGroupedTableImpl$2.class
org.apache.kafka.streams.kstream.internals.KGroupedTableImpl$3.class
org.apache.kafka.streams.kstream.internals.KGroupedTableImpl.class
org.apache.kafka.streams.kstream.internals.KStreamAggProcessorSupplier.class
org.apache.kafka.streams.kstream.internals.KStreamAggregate$1.class
org.apache.kafka.streams.kstream.internals.KStreamAggregate$KStreamAggregateProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamAggregate$KStreamAggregateValueGetter.class
org.apache.kafka.streams.kstream.internals.KStreamAggregate.class
org.apache.kafka.streams.kstream.internals.KStreamBranch$1.class
org.apache.kafka.streams.kstream.internals.KStreamBranch$KStreamBranchProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamBranch.class
org.apache.kafka.streams.kstream.internals.KStreamFilter$1.class
org.apache.kafka.streams.kstream.internals.KStreamFilter$KStreamFilterProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamFilter.class
org.apache.kafka.streams.kstream.internals.KStreamFlatMap$1.class
org.apache.kafka.streams.kstream.internals.KStreamFlatMap$KStreamFlatMapProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamFlatMap.class
org.apache.kafka.streams.kstream.internals.KStreamFlatMapValues$1.class
org.apache.kafka.streams.kstream.internals.KStreamFlatMapValues$KStreamFlatMapValuesProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamFlatMapValues.class
org.apache.kafka.streams.kstream.internals.KStreamForeach$1.class
org.apache.kafka.streams.kstream.internals.KStreamForeach$KStreamForeachProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamForeach.class
org.apache.kafka.streams.kstream.internals.KStreamImpl$1.class
org.apache.kafka.streams.kstream.internals.KStreamImpl$2.class
org.apache.kafka.streams.kstream.internals.KStreamImpl$DefaultJoin.class
org.apache.kafka.streams.kstream.internals.KStreamImpl$KStreamImplJoin.class
org.apache.kafka.streams.kstream.internals.KStreamImpl$LeftJoin.class
org.apache.kafka.streams.kstream.internals.KStreamImpl.class
org.apache.kafka.streams.kstream.internals.KStreamJoinWindow$1.class
org.apache.kafka.streams.kstream.internals.KStreamJoinWindow$KStreamJoinWindowProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamJoinWindow.class
org.apache.kafka.streams.kstream.internals.KStreamKStreamJoin$1.class
org.apache.kafka.streams.kstream.internals.KStreamKStreamJoin$KStreamKStreamJoinProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamKStreamJoin.class
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoin$KStreamKTableLeftJoinProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoin.class
org.apache.kafka.streams.kstream.internals.KStreamMap$1.class
org.apache.kafka.streams.kstream.internals.KStreamMap$KStreamMapProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamMap.class
org.apache.kafka.streams.kstream.internals.KStreamMapValues$1.class
org.apache.kafka.streams.kstream.internals.KStreamMapValues$KStreamMapProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamMapValues.class
org.apache.kafka.streams.kstream.internals.KStreamPassThrough$KStreamPassThroughProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamPassThrough.class
org.apache.kafka.streams.kstream.internals.KStreamReduce$1.class
org.apache.kafka.streams.kstream.internals.KStreamReduce$KStreamReduceProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamReduce$KStreamReduceValueGetter.class
org.apache.kafka.streams.kstream.internals.KStreamReduce.class
org.apache.kafka.streams.kstream.internals.KStreamTransform$KStreamTransformProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamTransform.class
org.apache.kafka.streams.kstream.internals.KStreamTransformValues$KStreamTransformValuesProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamTransformValues.class
org.apache.kafka.streams.kstream.internals.KStreamWindowAggregate$1.class
org.apache.kafka.streams.kstream.internals.KStreamWindowAggregate$KStreamWindowAggregateProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamWindowAggregate$KStreamWindowAggregateValueGetter.class
org.apache.kafka.streams.kstream.internals.KStreamWindowAggregate.class
org.apache.kafka.streams.kstream.internals.KStreamWindowReduce$1.class
org.apache.kafka.streams.kstream.internals.KStreamWindowReduce$KStreamWindowReduceProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamWindowReduce$KStreamWindowReduceValueGetter.class
org.apache.kafka.streams.kstream.internals.KStreamWindowReduce.class
org.apache.kafka.streams.kstream.internals.KTableAggregate$1.class
org.apache.kafka.streams.kstream.internals.KTableAggregate$KTableAggregateProcessor.class
org.apache.kafka.streams.kstream.internals.KTableAggregate$KTableAggregateValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableAggregate.class
org.apache.kafka.streams.kstream.internals.KTableFilter$1.class
org.apache.kafka.streams.kstream.internals.KTableFilter$KTableFilterProcessor.class
org.apache.kafka.streams.kstream.internals.KTableFilter$KTableFilterValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableFilter.class
org.apache.kafka.streams.kstream.internals.KTableImpl$1.class
org.apache.kafka.streams.kstream.internals.KTableImpl$2.class
org.apache.kafka.streams.kstream.internals.KTableImpl.class
org.apache.kafka.streams.kstream.internals.KTableKTableAbstractJoin.class
org.apache.kafka.streams.kstream.internals.KTableKTableJoin$KTableKTableJoinProcessor.class
org.apache.kafka.streams.kstream.internals.KTableKTableJoin$KTableKTableJoinValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableKTableJoin$KTableKTableJoinValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.KTableKTableJoin.class
org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$1.class
org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$KTableKTableJoinMergeProcessor.class
org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger.class
org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinProcessor.class
org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin.class
org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoin$KTableKTableOuterJoinProcessor.class
org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoin$KTableKTableOuterJoinValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoin$KTableKTableOuterJoinValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoin.class
org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.class
org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin.class
org.apache.kafka.streams.kstream.internals.KTableMapValues$1.class
org.apache.kafka.streams.kstream.internals.KTableMapValues$KTableMapValuesProcessor.class
org.apache.kafka.streams.kstream.internals.KTableMapValues$KTableMapValuesValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableMapValues.class
org.apache.kafka.streams.kstream.internals.KTableProcessorSupplier.class
org.apache.kafka.streams.kstream.internals.KTableReduce$1.class
org.apache.kafka.streams.kstream.internals.KTableReduce$KTableAggregateValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableReduce$KTableReduceProcessor.class
org.apache.kafka.streams.kstream.internals.KTableReduce.class
org.apache.kafka.streams.kstream.internals.KTableRepartitionMap$1.class
org.apache.kafka.streams.kstream.internals.KTableRepartitionMap$KTableMapProcessor.class
org.apache.kafka.streams.kstream.internals.KTableRepartitionMap$KTableMapValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableRepartitionMap.class
org.apache.kafka.streams.kstream.internals.KTableSource$1.class
org.apache.kafka.streams.kstream.internals.KTableSource$KTableSourceProcessor.class
org.apache.kafka.streams.kstream.internals.KTableSource.class
org.apache.kafka.streams.kstream.internals.KTableSourceValueGetterSupplier$1.class
org.apache.kafka.streams.kstream.internals.KTableSourceValueGetterSupplier$KTableSourceValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableSourceValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.KTableValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.TimeWindow.class
org.apache.kafka.streams.kstream.internals.UnlimitedWindow.class
org.apache.kafka.streams.kstream.internals.WindowedDeserializer.class
org.apache.kafka.streams.kstream.internals.WindowedSerializer.class
org.apache.kafka.streams.kstream.internals.WindowedStreamPartitioner.class
org.apache.kafka.streams.kstream.JoinWindows.class
org.apache.kafka.streams.kstream.KeyValueMapper.class
org.apache.kafka.streams.kstream.KGroupedStream.class
org.apache.kafka.streams.kstream.KGroupedTable.class
org.apache.kafka.streams.kstream.KStream.class
org.apache.kafka.streams.kstream.KStreamBuilder.class
org.apache.kafka.streams.kstream.KTable.class
org.apache.kafka.streams.kstream.Predicate.class
org.apache.kafka.streams.kstream.Reducer.class
org.apache.kafka.streams.kstream.TimeWindows.class
org.apache.kafka.streams.kstream.Transformer.class
org.apache.kafka.streams.kstream.TransformerSupplier.class
org.apache.kafka.streams.kstream.UnlimitedWindows.class
org.apache.kafka.streams.kstream.ValueJoiner.class
org.apache.kafka.streams.kstream.ValueMapper.class
org.apache.kafka.streams.kstream.ValueTransformer.class
org.apache.kafka.streams.kstream.ValueTransformerSupplier.class
org.apache.kafka.streams.kstream.Window.class
org.apache.kafka.streams.kstream.Windowed.class
org.apache.kafka.streams.kstream.Windows.class
org.apache.kafka.streams.processor.AbstractProcessor.class
org.apache.kafka.streams.processor.ConsumerRecordTimestampExtractor.class
org.apache.kafka.streams.processor.DefaultPartitionGrouper.class
org.apache.kafka.streams.processor.internals.AbstractTask.class
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfo.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.assignment.TaskAssignor$TaskPair.class
org.apache.kafka.streams.processor.internals.assignment.TaskAssignor.class
org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier.class
org.apache.kafka.streams.processor.internals.DefaultStreamPartitioner.class
org.apache.kafka.streams.processor.internals.InternalProcessorContext.class
org.apache.kafka.streams.processor.internals.InternalTopicConfig$CleanupPolicy.class
org.apache.kafka.streams.processor.internals.InternalTopicConfig.class
org.apache.kafka.streams.processor.internals.InternalTopicManager$1.class
org.apache.kafka.streams.processor.internals.InternalTopicManager$ZKStringSerializer.class
org.apache.kafka.streams.processor.internals.InternalTopicManager.class
org.apache.kafka.streams.processor.internals.MinTimestampTracker.class
org.apache.kafka.streams.processor.internals.PartitionGroup$1.class
org.apache.kafka.streams.processor.internals.PartitionGroup$RecordInfo.class
org.apache.kafka.streams.processor.internals.PartitionGroup.class
org.apache.kafka.streams.processor.internals.ProcessorContextImpl.class
org.apache.kafka.streams.processor.internals.ProcessorNode.class
org.apache.kafka.streams.processor.internals.ProcessorRecordContext.class
org.apache.kafka.streams.processor.internals.ProcessorStateManager.class
org.apache.kafka.streams.processor.internals.ProcessorTopology.class
org.apache.kafka.streams.processor.internals.PunctuationQueue.class
org.apache.kafka.streams.processor.internals.PunctuationSchedule.class
org.apache.kafka.streams.processor.internals.Punctuator.class
org.apache.kafka.streams.processor.internals.QuickUnion.class
org.apache.kafka.streams.processor.internals.RecordCollector$Supplier.class
org.apache.kafka.streams.processor.internals.RecordCollector.class
org.apache.kafka.streams.processor.internals.RecordCollectorImpl$1.class
org.apache.kafka.streams.processor.internals.RecordCollectorImpl.class
org.apache.kafka.streams.processor.internals.RecordContext.class
org.apache.kafka.streams.processor.internals.RecordQueue.class
org.apache.kafka.streams.processor.internals.SinkNode.class
org.apache.kafka.streams.processor.internals.SourceNode.class
org.apache.kafka.streams.processor.internals.Stamped.class
org.apache.kafka.streams.processor.internals.StampedRecord.class
org.apache.kafka.streams.processor.internals.StandbyContextImpl$1.class
org.apache.kafka.streams.processor.internals.StandbyContextImpl.class
org.apache.kafka.streams.processor.internals.StandbyTask.class
org.apache.kafka.streams.processor.internals.StateDirectory$1.class
org.apache.kafka.streams.processor.internals.StateDirectory.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor$1.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor$AssignedPartition.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor$AssignmentSupplier.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor$SubscriptionUpdates.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor.class
org.apache.kafka.streams.processor.internals.StreamsMetadataState$1.class
org.apache.kafka.streams.processor.internals.StreamsMetadataState$SourceTopicsInfo.class
org.apache.kafka.streams.processor.internals.StreamsMetadataState.class
org.apache.kafka.streams.processor.internals.StreamTask.class
org.apache.kafka.streams.processor.internals.StreamThread$1.class
org.apache.kafka.streams.processor.internals.StreamThread$2.class
org.apache.kafka.streams.processor.internals.StreamThread$3.class
org.apache.kafka.streams.processor.internals.StreamThread$4.class
org.apache.kafka.streams.processor.internals.StreamThread$5.class
org.apache.kafka.streams.processor.internals.StreamThread$AbstractTaskAction.class
org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsImpl.class
org.apache.kafka.streams.processor.internals.StreamThread.class
org.apache.kafka.streams.processor.internals.TimestampTracker.class
org.apache.kafka.streams.processor.PartitionGrouper.class
org.apache.kafka.streams.processor.Processor.class
org.apache.kafka.streams.processor.ProcessorContext.class
org.apache.kafka.streams.processor.ProcessorSupplier.class
org.apache.kafka.streams.processor.StateRestoreCallback.class
org.apache.kafka.streams.processor.StateStore.class
org.apache.kafka.streams.processor.StateStoreSupplier.class
org.apache.kafka.streams.processor.StreamPartitioner.class
org.apache.kafka.streams.processor.TaskId.class
org.apache.kafka.streams.processor.TimestampExtractor.class
org.apache.kafka.streams.processor.TopologyBuilder$1.class
org.apache.kafka.streams.processor.TopologyBuilder$NodeFactory.class
org.apache.kafka.streams.processor.TopologyBuilder$ProcessorNodeFactory.class
org.apache.kafka.streams.processor.TopologyBuilder$SinkNodeFactory.class
org.apache.kafka.streams.processor.TopologyBuilder$SourceNodeFactory.class
org.apache.kafka.streams.processor.TopologyBuilder$StateStoreFactory.class
org.apache.kafka.streams.processor.TopologyBuilder$TopicsInfo.class
org.apache.kafka.streams.processor.TopologyBuilder.class
org.apache.kafka.streams.processor.WallclockTimestampExtractor.class
org.apache.kafka.streams.state.HostInfo.class
org.apache.kafka.streams.state.internals.AbstractStoreSupplier.class
org.apache.kafka.streams.state.internals.CachedStateStore.class
org.apache.kafka.streams.state.internals.CachingKeyValueStore$1.class
org.apache.kafka.streams.state.internals.CachingKeyValueStore.class
org.apache.kafka.streams.state.internals.CachingWindowStore$1.class
org.apache.kafka.streams.state.internals.CachingWindowStore.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore$1.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore$2.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore$CompositeKeyValueIterator.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore$NextIteratorFunction.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStore$1.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStore.class
org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIterator.class
org.apache.kafka.streams.state.internals.DelegatingPeekingWindowIterator.class
org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStore$1.class
org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStore.class
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreSupplier$MemoryStore$1.class
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreSupplier$MemoryStore$MemoryStoreIterator.class
#内容未全部加载,请点击展开加载全部代码(NowJava.com)
|
依赖Jar: |
kafka-clients-0.10.1.1.jar
/org.apache.kafka/kafka-clients/0.10.1.1
查看kafka-clients所有版本文件
connect-json-0.10.1.1.jar
/org.apache.kafka/connect-json/0.10.1.1
查看connect-json所有版本文件
slf4j-api-1.7.21.jar
/org.slf4j/slf4j-api/1.7.21
查看slf4j-api所有版本文件
rocksdbjni-4.9.0.jar
/org.rocksdb/rocksdbjni/4.9.0
查看rocksdbjni所有版本文件
zkclient-0.9.jar
/com.101tec/zkclient/0.9
查看zkclient所有版本文件
log4j-1.2.17.jar
/log4j/log4j/1.2.17
查看log4j所有版本文件
jackson-databind-2.6.3.jar
/com.fasterxml.jackson.core/jackson-databind/2.6.3
查看jackson-databind所有版本文件
kafka_2.10-0.10.1.1.jar
/org.apache.kafka/kafka_2.10/0.10.1.1
查看kafka_2.10所有版本文件
junit-4.12.jar
/junit/junit/4.12
查看junit所有版本文件
slf4j-log4j12-1.7.21.jar
/org.slf4j/slf4j-log4j12/1.7.21
查看slf4j-log4j12所有版本文件
|