组织ID: |
org.apache.kafka |
项目ID: |
kafka-streams |
版本: |
1.1.1 |
最后修改时间: |
2018-07-28 16:11:14 |
包类型: |
jar |
标题: |
Apache Kafka |
相关URL: |
http://kafka.apache.org |
大小: |
804.63KB |
|
Maven引入代码: |
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-streams</artifactId>
<version>1.1.1</version>
</dependency>
|
Gradle引入代码: |
org.apache.kafka:kafka-streams:1.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>1.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>1.1.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>connect-json</artifactId>
<version>1.1.1</version>
<scope>compile</scope>
</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.7.3</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.11</artifactId>
<version>1.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.easymock</groupId>
<artifactId>easymock</artifactId>
<version>3.6</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.bouncycastle</groupId>
<artifactId>bcpkix-jdk15on</artifactId>
<version>1.59</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$2.class
org.apache.kafka.streams.KafkaStreams$State.class
org.apache.kafka.streams.KafkaStreams.class
org.apache.kafka.streams.errors.TopologyException.class
org.apache.kafka.streams.errors.LockException.class
org.apache.kafka.streams.errors.LogAndContinueExceptionHandler.class
org.apache.kafka.streams.errors.TaskIdFormatException.class
org.apache.kafka.streams.errors.DeserializationExceptionHandler$DeserializationHandlerResponse.class
org.apache.kafka.streams.errors.ProductionExceptionHandler$ProductionExceptionHandlerResponse.class
org.apache.kafka.streams.errors.StreamsException.class
org.apache.kafka.streams.errors.LogAndFailExceptionHandler.class
org.apache.kafka.streams.errors.ProductionExceptionHandler.class
org.apache.kafka.streams.errors.TopologyBuilderException.class
org.apache.kafka.streams.errors.DefaultProductionExceptionHandler.class
org.apache.kafka.streams.errors.TaskMigratedException.class
org.apache.kafka.streams.errors.InvalidStateStoreException.class
org.apache.kafka.streams.errors.TaskAssignmentException.class
org.apache.kafka.streams.errors.BrokerNotFoundException.class
org.apache.kafka.streams.errors.ProcessorStateException.class
org.apache.kafka.streams.errors.DeserializationExceptionHandler.class
org.apache.kafka.streams.KafkaClientSupplier.class
org.apache.kafka.streams.TopologyDescription$Node.class
org.apache.kafka.streams.TopologyDescription$Source.class
org.apache.kafka.streams.TopologyDescription$GlobalStore.class
org.apache.kafka.streams.processor.AbstractProcessor.class
org.apache.kafka.streams.processor.TaskId.class
org.apache.kafka.streams.processor.BatchingStateRestoreCallback.class
org.apache.kafka.streams.processor.TopologyBuilder$TopicsInfo.class
org.apache.kafka.streams.processor.ProcessorSupplier.class
org.apache.kafka.streams.processor.Processor.class
org.apache.kafka.streams.processor.TopologyBuilder.class
org.apache.kafka.streams.processor.TopologyBuilder$AutoOffsetReset.class
org.apache.kafka.streams.processor.StreamPartitioner.class
org.apache.kafka.streams.processor.internals.PunctuationQueue.class
org.apache.kafka.streams.processor.internals.PunctuationSchedule$1.class
org.apache.kafka.streams.processor.internals.RecordCollector.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$AbstractNode.class
org.apache.kafka.streams.processor.internals.InternalTopicConfig.class
org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener.class
org.apache.kafka.streams.processor.internals.GlobalStreamThread.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$AbstractStateStoreFactory.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor$ClientMetadata.class
org.apache.kafka.streams.processor.internals.GlobalStateManagerImpl.class
org.apache.kafka.streams.processor.internals.AssignedStreamsTasks$1.class
org.apache.kafka.streams.processor.internals.ChangelogReader.class
org.apache.kafka.streams.processor.internals.PartitionGroup$1.class
org.apache.kafka.streams.processor.internals.StandbyTask.class
org.apache.kafka.streams.processor.internals.StoreChangelogReader.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$StoreBuilderFactory.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$TopicsInfo.class
org.apache.kafka.streams.processor.internals.StreamTask.class
org.apache.kafka.streams.processor.internals.ProcessorNode$2.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$StateStoreSupplierFactory.class
org.apache.kafka.streams.processor.internals.StreamsMetadataState$SourceTopicsInfo.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$NodeFactory.class
org.apache.kafka.streams.processor.internals.StreamThread$StandbyTaskCreator.class
org.apache.kafka.streams.processor.internals.StreamsMetadataState.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$StateStoreFactory.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$NodeComparator.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor$AssignedPartition.class
org.apache.kafka.streams.processor.internals.GlobalStateMaintainer.class
org.apache.kafka.streams.processor.internals.PartitionGroup.class
org.apache.kafka.streams.processor.internals.ProcessorNode$4.class
org.apache.kafka.streams.processor.internals.PartitionGroup$RecordInfo.class
org.apache.kafka.streams.processor.internals.ProcessorNode.class
org.apache.kafka.streams.processor.internals.AbstractTask.class
org.apache.kafka.streams.processor.internals.AssignedTasks$1.class
org.apache.kafka.streams.processor.internals.AbstractProcessorContext.class
org.apache.kafka.streams.processor.internals.StreamTask$TaskMetrics.class
org.apache.kafka.streams.processor.internals.DefaultStreamPartitioner.class
org.apache.kafka.streams.processor.internals.ProcessorNodePunctuator.class
org.apache.kafka.streams.processor.internals.QuickUnion.class
org.apache.kafka.streams.processor.internals.AbstractStateManager.class
org.apache.kafka.streams.processor.internals.ProcessorRecordContext.class
org.apache.kafka.streams.processor.internals.WindowedChangelogTopicConfig.class
org.apache.kafka.streams.processor.internals.AssignedStreamsTasks.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$SourceNodeFactory.class
org.apache.kafka.streams.processor.internals.MinTimestampTracker.class
org.apache.kafka.streams.processor.internals.Task.class
org.apache.kafka.streams.processor.internals.RecordDeserializer.class
org.apache.kafka.streams.processor.internals.ProcessorNode$3.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor$SubscriptionUpdates.class
org.apache.kafka.streams.processor.internals.PunctuationSchedule$RepointableCancellable.class
org.apache.kafka.streams.processor.internals.AssignedTasks.class
org.apache.kafka.streams.processor.internals.StandbyContextImpl$1.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$GlobalStoreComparator.class
org.apache.kafka.streams.processor.internals.InternalProcessorContext.class
org.apache.kafka.streams.processor.internals.CompositeRestoreListener.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$TopologyDescription.class
org.apache.kafka.streams.processor.internals.ProcessorStateManager.class
org.apache.kafka.streams.processor.internals.StreamThread.class
org.apache.kafka.streams.processor.internals.StreamTask$1.class
org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator.class
org.apache.kafka.streams.processor.internals.GlobalStreamThread$StateConsumer.class
org.apache.kafka.streams.processor.internals.RecordCollectorImpl.class
org.apache.kafka.streams.processor.internals.StreamTask$2.class
org.apache.kafka.streams.processor.internals.InternalTopicManager.class
org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier.class
org.apache.kafka.streams.processor.internals.GlobalStreamThread$State.class
org.apache.kafka.streams.processor.internals.RecordCollectorImpl$1.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$Sink.class
org.apache.kafka.streams.processor.internals.RepartitionTopicConfig.class
org.apache.kafka.streams.processor.internals.ProcessorNode$1.class
org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.class
org.apache.kafka.streams.processor.internals.StampedRecord.class
org.apache.kafka.streams.processor.internals.Stamped.class
org.apache.kafka.streams.processor.internals.CompositeRestoreListener$NoOpStateRestoreListener.class
org.apache.kafka.streams.processor.internals.Checkpointable.class
org.apache.kafka.streams.processor.internals.SourceNode.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$SubtopologyComparator.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$1.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$ProcessorNodeFactory.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$Subtopology.class
org.apache.kafka.streams.processor.internals.StateDirectory.class
org.apache.kafka.streams.processor.internals.StreamThread$AbstractTaskCreator.class
org.apache.kafka.streams.processor.internals.WrappedBatchingStateRestoreCallback.class
org.apache.kafka.streams.processor.internals.TimestampTracker.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$Processor.class
org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl.class
org.apache.kafka.streams.processor.internals.TaskManager.class
org.apache.kafka.streams.processor.internals.ProcessorTopology.class
org.apache.kafka.streams.processor.internals.RecordContext.class
org.apache.kafka.streams.processor.internals.StandbyContextImpl.class
org.apache.kafka.streams.processor.internals.GlobalProcessorContextImpl.class
org.apache.kafka.streams.processor.internals.AssignedStandbyTasks.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor$CopartitionedTopicsValidator.class
org.apache.kafka.streams.processor.internals.UnwindowedChangelogTopicConfig.class
org.apache.kafka.streams.processor.internals.RecordQueue.class
org.apache.kafka.streams.processor.internals.StreamThread$StateListener.class
org.apache.kafka.streams.processor.internals.StreamThread$State.class
org.apache.kafka.streams.processor.internals.TaskAction.class
org.apache.kafka.streams.processor.internals.ProcessorNode$NodeMetrics.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$GlobalStore.class
org.apache.kafka.streams.processor.internals.StateRestorer.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor$1.class
org.apache.kafka.streams.processor.internals.RecordCollector$Supplier.class
org.apache.kafka.streams.processor.internals.CompositeRestoreListener$1.class
org.apache.kafka.streams.processor.internals.ThreadStateTransitionValidator.class
org.apache.kafka.streams.processor.internals.GlobalStateManager.class
org.apache.kafka.streams.processor.internals.StateDirectory$1.class
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignor$TaskPairs$Pair.class
org.apache.kafka.streams.processor.internals.assignment.ClientState.class
org.apache.kafka.streams.processor.internals.assignment.TaskAssignor.class
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfo.class
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignor$TaskPairs.class
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignor.class
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfo.class
org.apache.kafka.streams.processor.internals.ProcessorContextImpl$1.class
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor$InternalTopicMetadata.class
org.apache.kafka.streams.processor.internals.SinkNode.class
org.apache.kafka.streams.processor.internals.StreamsMetadataState$1.class
org.apache.kafka.streams.processor.internals.RestoringTasks.class
org.apache.kafka.streams.processor.internals.PunctuationSchedule.class
org.apache.kafka.streams.processor.internals.StateManager.class
org.apache.kafka.streams.processor.internals.GlobalStateUpdateTask.class
org.apache.kafka.streams.processor.internals.ProcessorContextImpl.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$Source.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$SubscriptionUpdates.class
org.apache.kafka.streams.processor.internals.InternalTopologyBuilder$SinkNodeFactory.class
org.apache.kafka.streams.processor.internals.StateDirectory$LockAndOwner.class
org.apache.kafka.streams.processor.WallclockTimestampExtractor.class
org.apache.kafka.streams.processor.TaskMetadata.class
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestamp.class
org.apache.kafka.streams.processor.ProcessorContext.class
org.apache.kafka.streams.processor.ExtractRecordMetadataTimestamp.class
org.apache.kafka.streams.processor.DefaultPartitionGrouper.class
org.apache.kafka.streams.processor.StateRestoreListener.class
org.apache.kafka.streams.processor.PartitionGrouper.class
org.apache.kafka.streams.processor.Cancellable.class
org.apache.kafka.streams.processor.StateStoreSupplier.class
org.apache.kafka.streams.processor.PunctuationType.class
org.apache.kafka.streams.processor.ThreadMetadata.class
org.apache.kafka.streams.processor.StateStore.class
org.apache.kafka.streams.processor.AbstractNotifyingRestoreCallback.class
org.apache.kafka.streams.processor.TimestampExtractor.class
org.apache.kafka.streams.processor.FailOnInvalidTimestamp.class
org.apache.kafka.streams.processor.Punctuator.class
org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestamp.class
org.apache.kafka.streams.processor.AbstractNotifyingBatchingRestoreCallback.class
org.apache.kafka.streams.processor.StateRestoreCallback.class
org.apache.kafka.streams.KafkaStreams$StreamStateListener.class
org.apache.kafka.streams.StreamsConfig.class
org.apache.kafka.streams.Topology.class
org.apache.kafka.streams.Topology$AutoOffsetReset.class
org.apache.kafka.streams.StreamsMetrics.class
org.apache.kafka.streams.Consumed.class
org.apache.kafka.streams.TopologyDescription$Processor.class
org.apache.kafka.streams.KeyValue.class
org.apache.kafka.streams.KafkaStreams$1.class
org.apache.kafka.streams.KafkaStreams$StateListener.class
org.apache.kafka.streams.TopologyDescription.class
org.apache.kafka.streams.KafkaStreams$DelegatingStateRestoreListener.class
org.apache.kafka.streams.TopologyDescription$Sink.class
org.apache.kafka.streams.KafkaStreams$3.class
org.apache.kafka.streams.TopologyDescription$Subtopology.class
org.apache.kafka.streams.state.Stores$3$1$1.class
org.apache.kafka.streams.state.StoreSupplier.class
org.apache.kafka.streams.state.Stores$3$1.class
org.apache.kafka.streams.state.Stores$PersistentKeyValueFactory.class
org.apache.kafka.streams.state.Stores$InMemoryKeyValueFactory.class
org.apache.kafka.streams.state.internals.RocksDbSessionBytesStoreSupplier.class
org.apache.kafka.streams.state.internals.RocksDBSessionStore$RocksDBSessionBytesStore.class
org.apache.kafka.streams.state.internals.SegmentedBytesStore$KeySchema.class
org.apache.kafka.streams.state.internals.WrappedSessionStoreIterator.class
org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreSupplier.class
org.apache.kafka.streams.state.internals.MeteredKeyValueBytesStore.class
org.apache.kafka.streams.state.internals.KeyValueIterators$EmptyKeyValueIterator.class
org.apache.kafka.streams.state.internals.QueryableStoreProvider.class
org.apache.kafka.streams.state.internals.PeekingKeyValueIterator.class
org.apache.kafka.streams.state.internals.InMemoryKeyValueStore$InMemoryKeyValueIterator.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStore$3.class
org.apache.kafka.streams.state.internals.WrappingStoreProvider.class
org.apache.kafka.streams.state.internals.FilteredCacheIterator.class
org.apache.kafka.streams.state.internals.CachingKeyValueStore.class
org.apache.kafka.streams.state.internals.WindowKeySchema.class
org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStore.class
org.apache.kafka.streams.state.internals.StreamThreadStateStoreProvider.class
org.apache.kafka.streams.state.internals.MeteredWindowedKeyValueIterator.class
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore$MeteredKeyValueIterator.class
org.apache.kafka.streams.state.internals.RocksDbWindowBytesStoreSupplier.class
org.apache.kafka.streams.state.internals.ThreadCache$MemoryLRUCacheBytesIterator.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.CachedStateStore.class
org.apache.kafka.streams.state.internals.MemoryLRUCache$1.class
org.apache.kafka.streams.state.internals.WindowStoreIteratorWrapper$WrappedWindowStoreBytesIterator.class
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore$TypeConverter.class
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStore$1.class
org.apache.kafka.streams.state.internals.MeteredKeyValueStore.class
org.apache.kafka.streams.state.internals.MemoryLRUCache$EldestEntryRemovalListener.class
org.apache.kafka.streams.state.internals.SegmentIterator.class
org.apache.kafka.streams.state.internals.StoreChangeLogger.class
org.apache.kafka.streams.state.internals.MeteredWindowStore.class
org.apache.kafka.streams.state.internals.MemoryLRUCache.class
org.apache.kafka.streams.state.internals.WrappedStateStore.class
org.apache.kafka.streams.state.internals.MemoryLRUCache$2.class
org.apache.kafka.streams.state.internals.KeyValueStoreBuilder.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore.class
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore$3.class
org.apache.kafka.streams.state.internals.KeyValueIterators$1.class
org.apache.kafka.streams.state.internals.ThreadCache$DirtyEntry.class
org.apache.kafka.streams.state.internals.MemoryNavigableLRUCache.class
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore$Action.class
org.apache.kafka.streams.state.internals.WindowStoreIteratorWrapper$WrappedKeyValueIterator.class
org.apache.kafka.streams.state.internals.MergedSortedCacheKeyValueBytesStoreIterator.class
org.apache.kafka.streams.state.internals.Segment.class
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore$6.class
org.apache.kafka.streams.state.internals.SessionKeySchema$1.class
org.apache.kafka.streams.state.internals.WrappedStateStore$AbstractStateStore.class
org.apache.kafka.streams.state.internals.WindowStoreIteratorWrapper.class
org.apache.kafka.streams.state.internals.NamedCache$LRUNode.class
org.apache.kafka.streams.state.internals.SessionKeySchema.class
org.apache.kafka.streams.state.internals.RocksDBWindowStoreSupplier.class
org.apache.kafka.streams.state.internals.WindowStoreIteratorWrapper$WrappedWindowStoreBytesIterator$1.class
org.apache.kafka.streams.state.internals.WindowStoreUtils.class
org.apache.kafka.streams.state.internals.MeteredKeyValueStore$1.class
org.apache.kafka.streams.state.internals.MergedSortedCacheWindowStoreIterator.class
org.apache.kafka.streams.state.internals.FilteredCacheIterator$1.class
org.apache.kafka.streams.state.internals.StateStoreProvider.class
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore$4.class
org.apache.kafka.streams.state.internals.DelegatingPeekingKeyValueIterator.class
org.apache.kafka.streams.state.internals.KeyValueIterators$EmptyWindowStoreIterator.class
org.apache.kafka.streams.state.internals.MemoryNavigableLRUCache$CacheIterator.class
org.apache.kafka.streams.state.internals.RocksDBStore.class
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore$5.class
org.apache.kafka.streams.state.internals.InMemoryKeyValueStore$1.class
org.apache.kafka.streams.state.internals.ThreadCache$DirtyEntryFlushListener.class
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore$2.class
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore$7.class
org.apache.kafka.streams.state.internals.MeteredSessionStore.class
org.apache.kafka.streams.state.internals.WindowStoreIteratorWrapper$WrappedWindowStoreIterator.class
org.apache.kafka.streams.state.internals.Segments.class
org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplier.class
org.apache.kafka.streams.state.internals.WindowStoreBuilder.class
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.class
org.apache.kafka.streams.state.internals.CachingSessionStore.class
org.apache.kafka.streams.state.internals.GlobalStateStoreProvider.class
org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStore$1.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStore.class
org.apache.kafka.streams.state.internals.WindowStoreIteratorWrapper$WrappedWindowStoreBytesIterator$2.class
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore$1.class
org.apache.kafka.streams.state.internals.InMemoryKeyValueStore.class
org.apache.kafka.streams.state.internals.SessionStoreBuilder.class
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore$1.class
org.apache.kafka.streams.state.internals.CacheFunction.class
org.apache.kafka.streams.state.internals.NextIteratorFunction.class
org.apache.kafka.streams.state.internals.RocksDBStore$1.class
org.apache.kafka.streams.state.internals.AbstractMergedSortedCacheStoreIterator.class
org.apache.kafka.streams.state.internals.CachingWindowStore.class
org.apache.kafka.streams.state.internals.LRUCacheEntry.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore$2.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore$1.class
org.apache.kafka.streams.state.internals.RocksDbKeyValueBytesStoreSupplier.class
org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplier.class
org.apache.kafka.streams.state.internals.ThreadCache.class
org.apache.kafka.streams.state.internals.MeteredWindowStoreIterator.class
org.apache.kafka.streams.state.internals.NamedCache.class
org.apache.kafka.streams.state.internals.CachingSessionStore$1.class
org.apache.kafka.streams.state.internals.CachingWindowStore$1.class
org.apache.kafka.streams.state.internals.MergedSortedCacheSessionStoreIterator.class
org.apache.kafka.streams.state.internals.RocksDBWindowStore.class
org.apache.kafka.streams.state.internals.AbstractStoreBuilder.class
org.apache.kafka.streams.state.internals.CachingKeyValueStore$1.class
org.apache.kafka.streams.state.internals.RocksDBWindowStore$RocksDBWindowBytesStore.class
org.apache.kafka.streams.state.internals.SegmentedBytesStore.class
org.apache.kafka.streams.state.internals.MeteredKeyValueBytesStore$1.class
org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStore$1.class
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore.class
org.apache.kafka.streams.state.internals.KeyValueIterators.class
org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStore.class
org.apache.kafka.streams.state.internals.CompositeKeyValueIterator.class
org.apache.kafka.streams.state.internals.RocksDBStore$RocksDbIterator.class
org.apache.kafka.streams.state.internals.AbstractStoreSupplier.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStore$2.class
org.apache.kafka.streams.state.internals.MergedSortedCacheWindowStoreKeyValueIterator.class
org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStore.class
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStore$1.class
org.apache.kafka.streams.state.internals.NamedCache$NamedCacheMetrics.class
org.apache.kafka.streams.state.internals.ChangeLoggingSessionBytesStore.class
org.apache.kafka.streams.state.internals.OffsetCheckpoint.class
org.apache.kafka.streams.state.internals.SegmentedCacheFunction.class
org.apache.kafka.streams.state.internals.WindowKeySchema$1.class
org.apache.kafka.streams.state.internals.WindowStoreSupplier.class
org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreSupplier.class
org.apache.kafka.streams.state.internals.WrappedSessionStoreIterator$WrappedSessionStoreBytesIterator.class
org.apache.kafka.streams.state.internals.HasNextCondition.class
org.apache.kafka.streams.state.internals.OrderedBytes.class
org.apache.kafka.streams.state.internals.ChangeLoggingWindowBytesStore.class
org.apache.kafka.streams.state.internals.RocksDBSessionStore.class
org.apache.kafka.streams.state.Stores$2.class
org.apache.kafka.streams.state.HostInfo.class
org.apache.kafka.streams.state.QueryableStoreTypes$QueryableStoreTypeMatcher.class
org.apache.kafka.streams.state.ReadOnlyWindowStore.class
org.apache.kafka.streams.state.Stores$3$1$1$2.class
org.apache.kafka.streams.state.Stores$ValueFactory.class
org.apache.kafka.streams.state.QueryableStoreTypes$KeyValueStoreType.class
org.apache.kafka.streams.state.Stores$3$1$1$1.class
org.apache.kafka.streams.state.KeyValueStore.class
org.apache.kafka.streams.state.Stores$1.class
org.apache.kafka.streams.state.SessionBytesStoreSupplier.class
org.apache.kafka.streams.state.StoreBuilder.class
org.apache.kafka.streams.state.RocksDBConfigSetter.class
org.apache.kafka.streams.state.Stores$StoreFactory.class
org.apache.kafka.streams.state.ReadOnlyKeyValueStore.class
org.apache.kafka.streams.state.Stores$KeyValueFactory.class
org.apache.kafka.streams.state.Stores.class
org.apache.kafka.streams.state.QueryableStoreType.class
org.apache.kafka.streams.state.KeyValueIterator.class
org.apache.kafka.streams.state.QueryableStoreTypes$WindowStoreType.class
org.apache.kafka.streams.state.WindowBytesStoreSupplier.class
org.apache.kafka.streams.state.QueryableStoreTypes$SessionStoreType.class
org.apache.kafka.streams.state.QueryableStoreTypes.class
org.apache.kafka.streams.state.Stores$3.class
org.apache.kafka.streams.state.StreamsMetadata.class
org.apache.kafka.streams.state.WindowStore.class
org.apache.kafka.streams.state.KeyValueBytesStoreSupplier.class
org.apache.kafka.streams.state.WindowStoreIterator.class
org.apache.kafka.streams.state.StateSerdes.class
org.apache.kafka.streams.state.ReadOnlySessionStore.class
org.apache.kafka.streams.state.SessionStore.class
org.apache.kafka.streams.kstream.SessionWindowedKStream.class
org.apache.kafka.streams.kstream.ValueMapperWithKey.class
org.apache.kafka.streams.kstream.Joined.class
org.apache.kafka.streams.kstream.Windows.class
org.apache.kafka.streams.kstream.ValueTransformerSupplier.class
org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger.class
org.apache.kafka.streams.kstream.internals.KStreamPassThrough$KStreamPassThroughProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamFlatMapValues.class
org.apache.kafka.streams.kstream.internals.KTableProcessorSupplier.class
org.apache.kafka.streams.kstream.internals.KStreamPassThrough.class
org.apache.kafka.streams.kstream.internals.KStreamReduce$KStreamReduceProcessor.class
org.apache.kafka.streams.kstream.internals.KTableMaterializedValueGetterSupplier$KTableMaterializedValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableRepartitionMap$KTableMapValueGetter.class
org.apache.kafka.streams.kstream.internals.KStreamKTableJoin.class
org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin.class
org.apache.kafka.streams.kstream.internals.ProducedInternal.class
org.apache.kafka.streams.kstream.internals.KStreamPrint$KStreamPrintProcessor.class
org.apache.kafka.streams.kstream.internals.MaterializedInternal.class
org.apache.kafka.streams.kstream.internals.KStreamTransformValues$KStreamTransformValuesProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamPeek$1.class
org.apache.kafka.streams.kstream.internals.KStreamMap.class
org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoin$1.class
org.apache.kafka.streams.kstream.internals.Change.class
org.apache.kafka.streams.kstream.internals.SessionKeySerde$SessionKeySerializer.class
org.apache.kafka.streams.kstream.internals.KTableFilter.class
org.apache.kafka.streams.kstream.internals.KTableMapValues$KTableMapValuesProcessor.class
org.apache.kafka.streams.kstream.internals.KTableValueGetter.class
org.apache.kafka.streams.kstream.internals.AbstractStream$4$1.class
org.apache.kafka.streams.kstream.internals.KGroupedStreamImpl$4.class
org.apache.kafka.streams.kstream.internals.KTableImpl$2.class
org.apache.kafka.streams.kstream.internals.KStreamImpl$KStreamImplJoin.class
org.apache.kafka.streams.kstream.internals.KStreamAggregate$1.class
org.apache.kafka.streams.kstream.internals.KGroupedStreamImpl$3.class
org.apache.kafka.streams.kstream.internals.KStreamPrint.class
org.apache.kafka.streams.kstream.internals.KTableImpl$4.class
org.apache.kafka.streams.kstream.internals.KTableValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.GroupedStreamAggregateBuilder.class
org.apache.kafka.streams.kstream.internals.KStreamFilter.class
org.apache.kafka.streams.kstream.internals.KGroupedStreamImpl$1.class
org.apache.kafka.streams.kstream.internals.KStreamBranch$1.class
org.apache.kafka.streams.kstream.internals.ForwardingCacheFlushListener.class
org.apache.kafka.streams.kstream.internals.KTableFilter$1.class
org.apache.kafka.streams.kstream.internals.KStreamGlobalKTableJoin.class
org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$KTableKTableJoinMergeProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamFlatMap.class
org.apache.kafka.streams.kstream.internals.KTableSourceValueGetterSupplier$1.class
org.apache.kafka.streams.kstream.internals.PrintForeachAction.class
org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregate$KTableSessionWindowValueGetter.class
org.apache.kafka.streams.kstream.internals.WindowedStreamPartitioner.class
org.apache.kafka.streams.kstream.internals.KStreamAggregate$KStreamAggregateValueGetter.class
org.apache.kafka.streams.kstream.internals.KeyValueStoreMaterializer.class
org.apache.kafka.streams.kstream.internals.KStreamWindowReduce$KStreamWindowReduceValueGetter.class
org.apache.kafka.streams.kstream.internals.InternalNameProvider.class
org.apache.kafka.streams.kstream.internals.InternalStreamsBuilder.class
org.apache.kafka.streams.kstream.internals.KTableAggregate.class
org.apache.kafka.streams.kstream.internals.KStreamMapValues.class
org.apache.kafka.streams.kstream.internals.InternalValueTransformerWithKeySupplier.class
org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinValueGetter.class
org.apache.kafka.streams.kstream.internals.KStreamFilter$KStreamFilterProcessor.class
org.apache.kafka.streams.kstream.internals.KTableAggregate$1.class
org.apache.kafka.streams.kstream.internals.AbstractStream$1.class
org.apache.kafka.streams.kstream.internals.AbstractStream$3.class
org.apache.kafka.streams.kstream.internals.KStreamImpl$3.class
org.apache.kafka.streams.kstream.internals.SessionKeySerde$SessionKeyDeserializer.class
org.apache.kafka.streams.kstream.internals.KStreamTransform.class
org.apache.kafka.streams.kstream.internals.KTableMaterializedValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.GroupedStreamAggregateBuilder$2.class
org.apache.kafka.streams.kstream.internals.SerializedInternal.class
org.apache.kafka.streams.kstream.internals.KTableImpl.class
org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinValueGetter.class
org.apache.kafka.streams.kstream.internals.KStreamImpl$1.class
org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoin$KTableKTableOuterJoinProcessor.class
org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.KTableAggregate$KTableAggregateProcessor.class
org.apache.kafka.streams.kstream.internals.KTableKTableAbstractJoinValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.KTableRepartitionMap$KTableMapProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamMapValues$1.class
org.apache.kafka.streams.kstream.internals.KStreamKStreamJoin.class
org.apache.kafka.streams.kstream.internals.AbstractStream.class
org.apache.kafka.streams.kstream.internals.KTableKTableOuterJoin.class
org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$1.class
org.apache.kafka.streams.kstream.internals.KTableSource.class
org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregate$1.class
org.apache.kafka.streams.kstream.internals.KGroupedTableImpl$2.class
org.apache.kafka.streams.kstream.internals.KStreamJoinWindow$1.class
org.apache.kafka.streams.kstream.internals.WindowedDeserializer.class
org.apache.kafka.streams.kstream.internals.KStreamTransform$KStreamTransformProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamKStreamJoin$KStreamKStreamJoinProcessor.class
org.apache.kafka.streams.kstream.internals.KStreamAggregate.class
org.apache.kafka.streams.kstream.internals.KStreamPassThrough$1.class
org.apache.kafka.streams.kstream.internals.KTableFilter$KTableFilterProcessor.class
org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoin$KTableKTableInnerJoinValueGetterSupplier.class
org.apache.kafka.streams.kstream.internals.KTableMapValues$1.class
org.apache.kafka.streams.kstream.internals.AbstractStream$2.class
org.apache.kafka.streams.kstream.internals.KStreamKTableJoin$1.class
org.apache.kafka.streams.kstream.internals.TupleForwarder.class
org.apache.kafka.streams.kstream.internals.KStreamFlatMapValues$1.class
org.apache.kafka.streams.kstream.internals.KTableReduce$1.class
org.apache.kafka.streams.kstream.internals.KTableMapValues$KTableMapValuesValueGetter.class
org.apache.kafka.streams.kstream.internals.KTableReduce.class
#内容未全部加载,请点击展开加载全部代码(NowJava.com)
|
依赖Jar: |
kafka-clients-1.1.1.jar
/org.apache.kafka/kafka-clients/1.1.1
查看kafka-clients所有版本文件
connect-json-1.1.1.jar
/org.apache.kafka/connect-json/1.1.1
查看connect-json所有版本文件
slf4j-api-1.7.25.jar
/org.slf4j/slf4j-api/1.7.25
查看slf4j-api所有版本文件
rocksdbjni-5.7.3.jar
/org.rocksdb/rocksdbjni/5.7.3
查看rocksdbjni所有版本文件
kafka_2.11-1.1.1.jar
/org.apache.kafka/kafka_2.11/1.1.1
查看kafka_2.11所有版本文件
junit-4.12.jar
/junit/junit/4.12
查看junit所有版本文件
easymock-3.6.jar
/org.easymock/easymock/3.6
查看easymock所有版本文件
bcpkix-jdk15on-1.59.jar
/org.bouncycastle/bcpkix-jdk15on/1.59
查看bcpkix-jdk15on所有版本文件
slf4j-log4j12-1.7.25.jar
/org.slf4j/slf4j-log4j12/1.7.25
查看slf4j-log4j12所有版本文件
|