Kafka 3.5.0源码包10.52MB-kafka-卡了网

PushHttpMetricsReporterTest.java 12KB

ProducerPerformanceTest.java 10KB

EndToEndLatencyTest.java 4KB

TransactionsCommandTest.java 35KB

JmxToolTest.java 9KB

ConsumerPerformanceTest.java 6KB

DelegationTokenCommandTest.java 5KB

MetadataQuorumCommandTest.java 8KB

VerifiableLog4jAppender.java 11KB

ClientCompatibilityTest.java 23KB

PushHttpMetricsReporter.java 12KB

StreamsResetter.java 36KB

TransactionalMessageCopier.java 19KB

ClusterTool.java 5KB

ConsumerPerformance.java 20KB

EndToEndLatency.java 10KB

MetadataQuorumCommand.java 9KB

JmxTool.java 20KB

VerifiableConsumer.java 24KB

TransactionsCommand.java 39KB

OAuthCompatibilityTool.java 20KB

VerifiableProducer.java 20KB

DelegationTokenCommand.java 15KB

ThroughputThrottler.java 5KB

ProducerPerformance.java 20KB

FileStreamSourceTaskTest.java 10KB

FileStreamSinkTaskTest.java 4KB

FileStreamSourceConnectorTest.java 6KB

FileStreamSourceConnector.java 4KB

FileStreamSourceTask.java 10KB

ConnectSchemaTest.java 15KB

ValuesTest.java 41KB

SchemaProjectorTest.java 25KB

SchemaBuilderTest.java 15KB

StructTest.java 15KB

SinkConnectorTest.java 4KB

SinkRecordTest.java 6KB

ConnectHeadersTest.java 23KB

SourceRecordTest.java 6KB

SourceConnectorTest.java 5KB

StringConverterTest.java 4KB

SimpleHeaderConverterTest.java 9KB

Values.java 55KB

Struct.java 10KB

SchemaBuilder.java 14KB

Schema.java 8KB

SchemaProjector.java 8KB

ConnectSchema.java 13KB

SinkRecord.java 4KB

SinkTaskContext.java 6KB

SinkTask.java 8KB

Headers.java 12KB

ConnectHeaders.java 16KB

SourceRecord.java 6KB

SourceTask.java 8KB

Converter.java 4KB

StringConverter.java 5KB

ConnectRecord.java 7KB

ConnectorClientConfigRequest.java 4KB

Connector.java 6KB

MirrorClientTest.java 10KB

MirrorClientConfig.java 7KB

Heartbeat.java 5KB

Checkpoint.java 7KB

MirrorClient.java 10KB

MirrorMakerConfigTest.java 22KB

MirrorCheckpointConfigTest.java 5KB

MirrorSourceConnectorTest.java 38KB

MirrorSourceMetricsTest.java 4KB

FakeForwardingAdminWithLocalMetadata.java 5KB

FakeLocalMetadataStore.java 5KB

OffsetSyncStoreTest.java 11KB

MirrorSourceConfigTest.java 10KB

MirrorSourceTaskTest.java 19KB

MirrorConnectorConfigTest.java 10KB

MirrorCheckpointConnectorTest.java 9KB

MirrorCheckpointTaskTest.java 14KB

DedicatedMirrorIntegrationTest.java 13KB

MirrorConnectorsIntegrationBaseTest.java 67KB

MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java 18KB

MirrorConnectorConfig.java 14KB

OffsetSync.java 4KB

MirrorCheckpointConnector.java 9KB

MirrorSourceMetrics.java 9KB

MirrorSourceTask.java 15KB

MirrorMaker.java 16KB

MirrorCheckpointTask.java 19KB

Scheduler.java 4KB

MirrorCheckpointMetrics.java 5KB

DefaultConfigPropertyFilter.java 5KB

MirrorSourceConfig.java 18KB

MirrorMakerConfig.java 15KB

MirrorSourceConnector.java 33KB

MirrorCheckpointConfig.java 12KB

OffsetSyncStore.java 16KB

MirrorUtils.java 7KB

README.md 12KB

KafkaStatusBackingStoreTest.java 17KB

KafkaStatusBackingStoreFormatTest.java 13KB

OffsetUtilsTest.java 7KB

OffsetStorageWriterTest.java 10KB

KafkaOffsetBackingStoreTest.java 28KB

KafkaConfigBackingStoreTest.java 92KB

FileOffsetBackingStoreTest.java 9KB

WorkerTestUtils.java 10KB

WorkerConnectorTest.java 25KB

MockConnectMetrics.java 9KB

ErrorHandlingTaskTest.java 27KB

SourceConnectorConfigTest.java 8KB

TransformationConfigTest.java 10KB

ConnectorConfigTest.java 20KB

ExactlyOnceWorkerSourceTaskTest.java 51KB

ConnectRestServerTest.java 18KB

InternalConnectResourceTest.java 9KB

ConnectorsResourceTest.java 44KB

ConnectorPluginsResourceTest.java 26KB

LoggingResourceTest.java 8KB

RestClientTest.java 11KB

RestServerConfigTest.java 7KB

InternalRequestSignatureTest.java 7KB

SSLUtilsTest.java 9KB

StandaloneHerderTest.java 55KB

RetryWithToleranceOperatorTest.java 21KB

ErrorReporterTest.java 16KB

WorkerErrantRecordReporterTest.java 4KB

ConnectClusterStateImplTest.java 4KB

SourceTaskOffsetCommitterTest.java 6KB

RestartPlanTest.java 5KB

AbstractHerderTest.java 61KB

RestartRequestTest.java 6KB

ConnectMetricsTest.java 7KB

WorkerConfigTransformerTest.java 6KB

WorkerTest.java 110KB

SubmittedRecordsTest.java 17KB

WorkerTaskTest.java 10KB

WorkerConfigTest.java 4KB

WorkerSinkTaskThreadedTest.java 29KB

WorkerSourceTaskTest.java 43KB

AbstractWorkerSourceTaskTest.java 35KB

WorkerCoordinatorTest.java 30KB

WorkerCoordinatorIncrementalTest.java 25KB

DistributedHerderTest.java 195KB

WorkerGroupMemberTest.java 6KB

DistributedConfigTest.java 22KB

ConnectProtocolCompatibilityTest.java 12KB

IncrementalCooperativeAssignorTest.java 67KB

WorkerMetricsGroupTest.java 8KB

DelegatingClassLoaderTest.java 5KB

SynchronizationTest.java 19KB

TestPlugins.java 17KB

PluginsTest.java 25KB

PluginDescTest.java 8KB

PluginUtilsTest.java 24KB

SamplingTestPlugin.java 4KB

WorkerSinkTaskTest.java 94KB

StateTrackerTest.java 5KB

TestFuture.java 5KB

RetryUtilTest.java 8KB

LoggingContextTest.java 7KB

TopicAdminTest.java 49KB

ConnectUtilsTest.java 7KB

EmbeddedConnectClusterAssertions.java 26KB

EmbeddedConnectCluster.java 41KB

EmbeddedKafkaCluster.java 31KB

KafkaBasedLogTest.java 25KB

TopicCreationTest.java 36KB

ConvertingFutureCallbackTest.java 9KB

SharedTopicAdminTest.java 4KB

ExactlyOnceSourceIntegrationTest.java 64KB

InternalTopicsIntegrationTest.java 16KB

StartAndStopCounter.java 6KB

MonitorableSinkConnector.java 6KB

SourceConnectorsIntegrationTest.java 12KB

StartAndStopLatch.java 5KB

ExampleConnectIntegrationTest.java 11KB

TaskHandle.java 13KB

TransformationIntegrationTest.java 15KB

OffsetsApiIntegrationTest.java 13KB

RestForwardingIntegrationTest.java 12KB

ConnectorTopicsIntegrationTest.java 16KB

StartAndStopLatchTest.java 5KB

ConnectorClientPolicyIntegrationTest.java 7KB

SinkConnectorsIntegrationTest.java 15KB

MonitorableSourceConnector.java 13KB

ErrorHandlingIntegrationTest.java 15KB

ConnectWorkerIntegrationTest.java 22KB

SessionedProtocolIntegrationTest.java 7KB

RestExtensionIntegrationTest.java 9KB

ConnectorHandle.java 15KB

RebalanceSourceConnectorsIntegrationTest.java 17KB

ConnectorRestartApiIntegrationTest.java 21KB

BlockingConnectorTest.java 29KB

SchemaSourceTask.java 7KB

VerifiableSinkTask.java 4KB

MockConnector.java 4KB

VerifiableSourceTask.java 7KB

TransformationDoc.java 5KB

NumberConverter.java 5KB

OffsetStorageReaderImpl.java 7KB

OffsetUtils.java 6KB

ClusterConfigState.java 12KB

KafkaOffsetBackingStore.java 20KB

KafkaStatusBackingStore.java 29KB

FileOffsetBackingStore.java 5KB

ConnectorOffsetBackingStore.java 16KB

MemoryConfigBackingStore.java 7KB

KafkaConfigBackingStore.java 67KB

ConfigBackingStore.java 6KB

StatusBackingStore.java 4KB

OffsetStorageWriter.java 11KB

MemoryStatusBackingStore.java 4KB

SubmittedRecords.java 16KB

RestartRequest.java 6KB

ConnectorConfig.java 29KB

WorkerConnector.java 22KB

SourceTaskOffsetCommitter.java 5KB

WorkerSinkTaskContext.java 6KB

ExactlyOnceWorkerSourceTask.java 24KB

ConnectMetricsRegistry.java 30KB

ConnectMetrics.java 17KB

Worker.java 96KB

SourceConnectorConfig.java 18KB

SinkConnectorConfig.java 9KB

StateTracker.java 8KB

HerderRequestHandler.java 7KB

RestServerConfig.java 19KB

ConnectorPluginsResource.java 7KB

ConnectorsResource.java 18KB

LoggingResource.java 8KB

InternalClusterResource.java 5KB

ConnectRestConfigurable.java 4KB

InternalRequestSignature.java 6KB

RestClient.java 11KB

ConfigKeyInfo.java 5KB

ConnectorStateInfo.java 4KB

RestServer.java 21KB

SSLUtils.java 8KB

StandaloneHerder.java 23KB

TopicCreationConfig.java 9KB

DeadLetterQueueReporter.java 10KB

ProcessingContext.java 8KB

RetryWithToleranceOperator.java 14KB

WorkerErrantRecordReporter.java 8KB

ErrorHandlingMetrics.java 5KB

ConnectClusterStateImpl.java 4KB

WorkerSinkTask.java 40KB

WorkerTransactionContext.java 4KB

WorkerSourceTask.java 15KB

WorkerTask.java 18KB

WorkerConfig.java 22KB

RestartPlan.java 5KB

WorkerConfigTransformer.java 4KB

Herder.java 14KB

WorkerMetricsGroup.java 8KB

AbstractWorkerSourceTask.java 31KB

AbstractHerder.java 40KB

DistributedHerder.java 136KB

EagerAssignor.java 9KB

IncrementalCooperativeAssignor.java 50KB

ExtendedAssignment.java 12KB

DistributedConfig.java 34KB

IncrementalCooperativeConnectProtocol.java 13KB

ConnectProtocolCompatibility.java 6KB

WorkerGroupMember.java 10KB

WorkerCoordinator.java 25KB

ConnectProtocol.java 16KB

PluginUtils.java 14KB

PluginClassLoader.java 5KB

DelegatingClassLoader.java 24KB

Plugins.java 23KB

PluginScanResult.java 5KB

AbstractConnectCli.java 7KB

ConnectDistributed.java 6KB

ConnectStandalone.java 5KB

TopicAdmin.java 37KB

ConnectUtils.java 10KB

ConvertingFutureCallback.java 4KB

KafkaBasedLog.java 30KB

SharedTopicAdmin.java 6KB

TopicCreation.java 6KB

TopicCreationGroup.java 6KB

RetryUtil.java 5KB

LoggingContext.java 9KB

JsonConverterTest.java 54KB

JsonConverter.java 35KB

JsonConverterConfig.java 6KB

JsonSchema.java 4KB

JaasBasicAuthFilterTest.java 12KB

BasicAuthSecurityRestExtensionTest.java 5KB

PropertyFileLoginModule.java 6KB

BasicAuthSecurityRestExtension.java 5KB

JaasBasicAuthFilter.java 9KB

ExtractFieldTest.java 4KB

TimestampConverterTest.java 32KB

HasHeaderKeyTest.java 4KB

InsertHeaderTest.java 5KB

FlattenTest.java 17KB

InsertFieldTest.java 9KB

DropHeadersTest.java 5KB

CastTest.java 27KB

MaskFieldTest.java 13KB

SetSchemaMetadataTest.java 7KB

HeaderFromTest.java 17KB

ReplaceFieldTest.java 6KB

SetSchemaMetadata.java 7KB

Flatten.java 13KB

MaskField.java 9KB

TimestampConverter.java 22KB

ReplaceField.java 9KB

Cast.java 20KB

HoistField.java 5KB

HeaderFrom.java 10KB

ValueToKey.java 4KB

InsertField.java 11KB

ExtractField.java 5KB

TimestampRouter.java 4KB

StreamsSmokeTest.java 4KB

SmokeTestDriver.java 30KB

StreamsUpgradeTest.java 5KB

SmokeTestUtil.java 5KB

SmokeTestClient.java 12KB

StreamsUpgradeToCooperativeRebalanceTest.java 6KB

RepartitionTopicNamingTest.java 38KB

JoinWindowsTest.java 10KB

SlidingWindowsTest.java 4KB

MaterializedTest.java 5KB

TimeWindowedDeserializerTest.java 4KB

TimeWindowsTest.java 8KB

KTableAggregateTest.java 22KB

SlidingWindowedKStreamImplTest.java 22KB

KStreamTransformTest.java 7KB

FullChangeSerdeTest.java 5KB

SlidingWindowedCogroupedKStreamImplTest.java 14KB

KTableTransformValuesTest.java 23KB

KStreamKStreamLeftJoinTest.java 59KB

KStreamGlobalKTableJoinTest.java 11KB

InternalStreamsBuilderTest.java 65KB

KStreamKStreamJoinTest.java 116KB

SessionWindowedKStreamImplTest.java 18KB

KStreamFilterTest.java 4KB

ChangedSerdeTest.java 8KB

KStreamKTableJoinTest.java 17KB

KStreamWindowAggregateTest.java 57KB

KStreamSessionWindowAggregateProcessorTest.java 25KB

KStreamFlatTransformTest.java 5KB

TimestampedTupleForwarderTest.java 5KB

TimeWindowTest.java 5KB

KStreamSlidingWindowAggregateTest.java 93KB

KStreamFlatTransformValuesTest.java 5KB

KStreamKStreamSelfJoinTest.java 17KB

KStreamKTableLeftJoinTest.java 8KB

KStreamMapValuesTest.java 4KB

TimeWindowedKStreamImplTest.java 23KB

KTableFilterTest.java 27KB

GlobalKTableJoinsTest.java 5KB

SuppressScenarioTest.java 41KB

KStreamNewProcessorApiTest.java 6KB

KStreamFlatMapValuesTest.java 5KB

KStreamGlobalKTableLeftJoinTest.java 11KB

KTableMapValuesTest.java 15KB

KTableSuppressProcessorTest.java 23KB

KTableSuppressProcessorMetricsTest.java 9KB

KTableKTableInnerJoinTest.java 26KB

KStreamRepartitionTest.java 8KB

ForeignTableJoinProcessorSupplierTest.java 15KB

ResponseJoinProcessorSupplierTest.java 11KB

SubscriptionResponseWrapperSerdeTest.java 6KB

SubscriptionWrapperSerdeTest.java 12KB

SubscriptionReceiveProcessorSupplierTest.java 22KB

KStreamTransformValuesTest.java 7KB

KTableImplTest.java 25KB

TransformerSupplierAdapterTest.java 6KB

KStreamSplitTest.java 8KB

StreamsGraphTest.java 30KB

GraphGraceSearchUtilTest.java 9KB

SuppressTopologyTest.java 12KB

SessionWindowedCogroupedKStreamImplTest.java 18KB

KStreamKStreamOuterJoinTest.java 66KB

KStreamFlatMapTest.java 4KB

KTableKTableLeftJoinTest.java 30KB

AbstractStreamTest.java 6KB

KGroupedStreamImplTest.java 36KB

KTableKTableOuterJoinTest.java 25KB

KTableKTableForeignKeyJoinScenarioTest.java 11KB

KGroupedTableImplTest.java 15KB

TimeWindowedCogroupedKStreamImplTest.java 17KB

SessionWindowTest.java 5KB

KStreamMapTest.java 4KB

CogroupedKStreamImplTest.java 75KB

KTableSourceTest.java 16KB

KStreamImplValueJoinerWithKeyTest.java 9KB

KStreamImplTest.java 163KB

PrintedTest.java 5KB

WindowedSerdesTest.java 8KB

SessionWindowsTest.java 5KB

SuppressedTest.java 9KB

StreamsResetterTest.java 14KB

KafkaStreamsTest.java 61KB

StateRestoreCallbackAdapterTest.java 5KB

TaskExecutorTest.java 4KB

TasksTest.java 11KB

TopicPartitionMetadataTest.java 4KB

DefaultTaskExecutorTest.java 4KB

DefaultTaskManagerTest.java 7KB

DefaultStateUpdaterTest.java 85KB

NamedTopologyTest.java 16KB

StreamsMetricsImplTest.java 62KB

TopicMetricsTest.java 5KB

ThreadMetricsTest.java 21KB

ProcessorNodeMetricsTest.java 9KB

TaskMetricsTest.java 13KB

PartitionGrouperTest.java 5KB

ConstrainedPrioritySetTest.java 4KB

LegacySubscriptionInfoSerde.java 11KB

AssignmentTestUtils.java 24KB

StandbyTaskAssignmentUtilsTest.java 7KB

AssignmentInfoTest.java 12KB

TaskAssignorConvergenceTest.java 20KB

SubscriptionInfoTest.java 21KB

StickyTaskAssignorTest.java 35KB

ClientStateTest.java 24KB

TaskMovementTest.java 16KB

HighAvailabilityTaskAssignorTest.java 47KB

ClientTagAwareStandbyTaskAssignorTest.java 34KB

TaskManagerTest.java 236KB

ProcessorContextImplTest.java 31KB

StateDirectoryTest.java 35KB

PunctuationQueueTest.java 6KB

StreamThreadTotalBlockedTimeTest.java 4KB

CopartitionedTopicsEnforcerTest.java 10KB

RecordQueueTest.java 22KB

GlobalStateManagerImplTest.java 45KB

HandlingSourceTopicDeletionIntegrationTest.java 6KB

StreamsProducerTest.java 45KB

StreamsRebalanceListenerTest.java 6KB

InternalTopicConfigTest.java 6KB

StandbyTaskTest.java 28KB

ChangelogTopicsTest.java 12KB

ClientUtilsTest.java 10KB

KeyValueStoreMaterializerTest.java 13KB

AbstractProcessorContextTest.java 10KB

ProcessorMetadataTest.java 6KB

StoreChangelogReaderTest.java 67KB

StreamThreadTest.java 140KB

RackAwarenessStreamsPartitionAssignorTest.java 29KB

ActiveTaskCreatorTest.java 21KB

StreamsPartitionAssignorTest.java 115KB

ProcessorStateManagerTest.java 50KB

SourceNodeTest.java 5KB

TaskExecutionMetadataTest.java 5KB

RecordCollectorTest.java 68KB

StateManagerUtilTest.java 10KB

GlobalProcessorContextImplTest.java 10KB

RepartitionTopicsTest.java 22KB

ProcessorNodeTest.java 9KB

GlobalStreamThreadTest.java 13KB

StateConsumerTest.java 6KB

RepartitionWithMergeOptimizingTest.java 19KB

GlobalStateTaskTest.java 9KB

TaskMetadataImplTest.java 6KB

StreamsAssignmentScaleTest.java 12KB

RepartitionOptimizingTest.java 26KB

ReadOnlyTaskTest.java 7KB

InternalTopologyBuilderTest.java 60KB

StreamsMetadataStateTest.java 19KB

ThreadMetadataImplTest.java 9KB

HighAvailabilityStreamsPartitionAssignorTest.java 15KB

InternalTopicManagerTest.java 97KB

PartitionGroupTest.java 34KB

ProcessorTopologyTest.java 94KB

StreamTaskTest.java 116KB

WriteConsistencyVectorTest.java 6KB

StreamsSmokeTest.java 5KB

EosTestClient.java 7KB

StreamsNamedRepartitionTest.java 5KB

SmokeTestDriver.java 29KB

StreamsBrokerDownResilienceTest.java 7KB

StreamsUpgradeTest.java 19KB

SmokeTestUtil.java 5KB

StreamsUpgradeToCooperativeRebalanceTest.java 6KB

StreamsStandByReplicaTest.java 8KB

RelationalSmokeTestTest.java 5KB

StreamsOptimizedTest.java 7KB

SmokeTestClient.java 11KB

EosTestDriver.java 35KB

BrokerCompatibilityTest.java 8KB

RelationalSmokeTest.java 43KB

UniqueTopicSerdeScope.java 5KB

EqualityCheck.java 5KB

ClientMetricsTest.java 6KB

ApiUtilsTest.java 5KB

StreamsConfigTest.java 67KB

StreamsBuilderTest.java 52KB

StateSerdesTest.java 6KB

StreamsMetadataTest.java 6KB

StoresTest.java 15KB

KeyValueStoreTestDriver.java 19KB

QueryableStoreProviderTest.java 6KB

RocksDBTimestampedStoreTest.java 24KB

RocksDBVersionedStoreSegmentValueFormatterTest.java 19KB

ChangeLoggingTimestampedWindowBytesStoreTest.java 5KB

GlobalStateStoreProviderTest.java 11KB

ChangeLoggingKeyValueBytesStoreTest.java 12KB

MeteredVersionedKeyValueStoreTest.java 14KB

OffsetCheckpointTest.java 7KB

TimestampedSegmentsTest.java 15KB

ReadOnlyWindowStoreFacadeTest.java 10KB

MergedSortedCacheKeyValueBytesStoreIteratorTest.java 11KB

TimeOrderedWindowStoreTest.java 57KB

ReadOnlyWindowStoreStub.java 15KB

WindowStoreFetchTest.java 13KB

MeteredTimestampedWindowStoreTest.java 10KB

RocksDBMetricsRecorderGaugesTest.java 12KB

RocksDBMetricsRecorderTest.java 33KB

StateStoreMetricsTest.java 16KB

RocksDBMetricsTest.java 22KB

KeyValueSegmentsTest.java 15KB

MergedSortedCacheWrappedSessionStoreIteratorTest.java 7KB

CompositeReadOnlySessionStoreTest.java 10KB

AbstractDualSchemaRocksDBSegmentedBytesStoreTest.java 78KB

MergedSortedCacheWrappedWindowStoreIteratorTest.java 13KB

CachingPersistentWindowStoreTest.java 52KB

TimeOrderedKeyValueBufferTest.java 48KB

ChangeLoggingSessionBytesStoreTest.java 6KB

RocksDBStoreTest.java 55KB

InMemoryLRUCacheStoreTest.java 6KB

MeteredTimestampedKeyValueStoreTest.java 19KB

AbstractRocksDBSegmentedBytesStoreTest.java 41KB

MeteredKeyValueStoreTest.java 18KB

SessionStoreBuilderTest.java 7KB

CachingInMemorySessionStoreTest.java 41KB

CompositeReadOnlyWindowStoreTest.java 25KB

NamedCacheTest.java 11KB

ValueAndTimestampSerializerTest.java 4KB

TimeOrderedCachingPersistentWindowStoreTest.java 57KB

TimestampedKeyValueStoreBuilderTest.java 8KB

SessionKeySchemaTest.java 17KB

ChangeLoggingVersionedKeyValueBytesStoreTest.java 9KB

TimestampedSegmentTest.java 6KB

RocksDBRangeIteratorTest.java 17KB

WrappingStoreProviderTest.java 5KB

AbstractSessionBytesStoreTest.java 45KB

ChangeLoggingWindowBytesStoreTest.java 5KB

TimestampedWindowStoreBuilderTest.java 10KB

WindowKeySchemaTest.java 25KB

MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest.java 11KB

BufferValueTest.java 10KB

KeyValueSegmentTest.java 6KB

AbstractKeyValueStoreTest.java 25KB

MeteredSessionStoreTest.java 26KB

RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest.java 15KB

ReadOnlyKeyValueStoreFacadeTest.java 5KB

WindowStoreBuilderTest.java 8KB

InMemoryWindowStoreTest.java 8KB

ChangeLoggingTimestampedKeyValueBytesStoreTest.java 9KB

LogicalKeyValueSegmentTest.java 25KB

VersionedKeyValueStoreBuilderTest.java 5KB

RocksDBTimeOrderedWindowSegmentedBytesStoreTest.java 4KB

SegmentedCacheFunctionTest.java 4KB

CachingPersistentSessionStoreTest.java 40KB

FilteredCacheIteratorTest.java 5KB

ListValueStoreTest.java 8KB

LogicalKeyValueSegmentsTest.java 11KB

RocksDBVersionedStoreTest.java 40KB

MeteredWindowStoreTest.java 21KB

SessionStoreFetchTest.java 14KB

CompositeReadOnlyKeyValueStoreTest.java 20KB

RocksDBWindowStoreTest.java 33KB

SegmentIteratorTest.java 14KB

AbstractWindowBytesStoreTest.java 51KB

InMemoryKeyValueStoreTest.java 11KB

CachingInMemoryKeyValueStoreTest.java 24KB

KeyValueStoreBuilderTest.java 6KB

StreamThreadStateStoreProviderTest.java 21KB

ThreadCacheTest.java 28KB

KeyValueStoreWrapperTest.java 11KB

NoOpWindowStore.java 4KB

TopologyTest.java 112KB

PositionTest.java 8KB

StandbyTaskCreationIntegrationTest.java 8KB

JoinStoreIntegrationTest.java 8KB

EosIntegrationTest.java 51KB

AbstractJoinIntegrationTest.java 14KB

SmokeTestDriverIntegrationTest.java 7KB

EosV2UpgradeIntegrationTest.java 61KB

OptimizedKTableIntegrationTest.java 10KB

PurgeRepartitionTopicIntegrationTest.java 9KB

KTableKTableForeignKeyVersionedJoinIntegrationTest.java 13KB

KTableKTableForeignKeyJoinDistributedTest.java 10KB

RegexSourceIntegrationTest.java 24KB

KTableEfficientRangeQueryTest.java 11KB

StoreUpgradeIntegrationTest.java 47KB

GlobalKTableIntegrationTest.java 18KB

TaskAssignorIntegrationTest.java 8KB

EOSUncleanShutdownIntegrationTest.java 8KB

KTableSourceTopicRestartIntegrationTest.java 11KB

SuppressionIntegrationTest.java 24KB

StreamsUpgradeTestIntegrationTest.java 6KB

AbstractResetIntegrationTest.java 21KB

StreamStreamJoinIntegrationTest.java 21KB

RocksDBMetricsIntegrationTest.java 17KB

KafkaEmbedded.java 9KB

EmbeddedKafkaCluster.java 13KB

IntegrationTestUtils.java 73KB

KStreamTransformIntegrationTest.java 20KB

KStreamAggregationDedupIntegrationTest.java 12KB

LagFetchIntegrationTest.java 18KB

ConsistencyVectorIntegrationTest.java 10KB

SlidingWindowedKStreamIntegrationTest.java 23KB

KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest.java 17KB

SelfJoinUpgradeIntegrationTest.java 11KB

EmitOnChangeIntegrationTest.java 7KB

StateDirectoryIntegrationTest.java 12KB

FineGrainedAutoResetIntegrationTest.java 15KB

TableTableJoinIntegrationTest.java 51KB

MetricsReporterIntegrationTest.java 5KB

StoreQueryIntegrationTest.java 33KB

AdjustStreamThreadCountTest.java 21KB

RangeQueryIntegrationTest.java 12KB

KStreamAggregationIntegrationTest.java 63KB

RestoreIntegrationTest.java 27KB

StandbyTaskEOSMultiRebalanceIntegrationTest.java 13KB

IQv2StoreIntegrationTest.java 53KB

ResetPartitionTimeIntegrationTest.java 9KB

KStreamKStreamIntegrationTest.java 8KB

KTableKTableForeignKeyJoinIntegrationTest.java 33KB

GlobalKTableEOSIntegrationTest.java 21KB

KafkaStreamsCloseOptionsIntegrationTest.java 8KB

StreamTableJoinIntegrationTest.java 7KB

SuppressionDurabilityIntegrationTest.java 15KB

GlobalThreadShutDownOrderTest.java 8KB

JoinWithIncompleteMetadataIntegrationTest.java 5KB

PositionRestartIntegrationTest.java 26KB

VersionedKeyValueStoreIntegrationTest.java 37KB

StreamTableJoinTopologyOptimizationIntegrationTest.java 11KB

StreamsUncaughtExceptionHandlerIntegrationTest.java 16KB

KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java 14KB

StandbyTaskEOSIntegrationTest.java 16KB

QueryableStateIntegrationTest.java 58KB

KStreamRepartitionIntegrationTest.java 34KB

TaskMetadataIntegrationTest.java 9KB

MetricsIntegrationTest.java 42KB

NamedTopologyIntegrationTest.java 53KB

KTableKTableForeignKeyJoinMaterializationIntegrationTest.java 8KB

TimeWindowedKStreamIntegrationTest.java 24KB

IQv2IntegrationTest.java 19KB

ResetIntegrationTest.java 14KB

HighAvailabilityTaskAssignorIntegrationTest.java 15KB

InternalTopicIntegrationTest.java 12KB

PauseResumeIntegrationTest.java 19KB

MockInternalProcessorContext.java 7KB

MockApiFixedKeyProcessor.java 6KB

GenericInMemoryTimestampedKeyValueStore.java 6KB

MockApiProcessor.java 6KB

GenericInMemoryKeyValueStore.java 5KB

MockKeyValueStore.java 4KB

InternalMockProcessorContext.java 19KB

NoOpProcessorContext.java 6KB

MockRestoreConsumer.java 6KB

StreamsTestUtils.java 14KB

MockInternalNewProcessorContext.java 8KB

ReadOnlySessionStoreStub.java 8KB

Grouped.java 7KB

SessionWindows.java 10KB

Suppressed.java 9KB

Printed.java 5KB

ValueTransformer.java 5KB

TableJoined.java 8KB

JoinWindows.java 13KB

Branched.java 7KB

KStream.java 312KB

StreamJoined.java 14KB

TimeWindowedCogroupedKStream.java 18KB

Joined.java 9KB

UnlimitedWindows.java 4KB

WindowedSerdes.java 5KB

SessionWindowedCogroupedKStream.java 19KB

BranchedKStream.java 9KB

SlidingWindows.java 9KB

Window.java 4KB

KTableKTableJoinMerger.java 6KB

ChangedDeserializer.java 6KB

SlidingWindowedCogroupedKStreamImpl.java 7KB

KTableKTableLeftJoin.java 8KB

KTableAggregate.java 6KB

KTableMapValues.java 7KB

KStreamKTableJoinProcessor.java 5KB

BranchedKStreamImpl.java 5KB

KTableKTableInnerJoin.java 8KB

WrappingNullableUtils.java 5KB

ChangedSerializer.java 6KB

TimeWindowedKStreamImpl.java 14KB

KStreamAggregate.java 7KB

KGroupedTableImpl.java 12KB

KTableKTableOuterJoin.java 8KB

SlidingWindowedKStreamImpl.java 14KB

KTableFilter.java 8KB

CogroupedKStreamImpl.java 7KB

KStreamSlidingWindowAggregate.java 26KB

TimeWindowedCogroupedKStreamImpl.java 7KB

KTableTransformValues.java 9KB

AbstractStream.java 7KB

SessionWindowedCogroupedKStreamImpl.java 8KB

CogroupedStreamAggregateBuilder.java 16KB

KTableSource.java 7KB

KGroupedStreamImpl.java 11KB

KStreamKStreamSelfJoin.java 7KB

KStreamImplJoin.java 19KB

KTableReduce.java 5KB

KTableSuppressProcessorSupplier.java 10KB

StrictBufferConfigImpl.java 4KB

SuppressedInternal.java 5KB

SessionWindowedKStreamImpl.java 15KB

KStreamReduce.java 6KB

KTableRepartitionMap.java 9KB

SubscriptionWrapperSerde.java 10KB

SubscriptionResponseWrapperSerde.java 6KB

ForeignTableJoinProcessorSupplier.java 7KB

SubscriptionJoinProcessorSupplier.java 7KB

CombinedKeySchema.java 6KB

SubscriptionWrapper.java 5KB

ResponseJoinProcessorSupplier.java 6KB

SubscriptionReceiveProcessorSupplier.java 6KB

SubscriptionSendProcessorSupplier.java 11KB

KStreamWindowAggregate.java 9KB

KStreamKStreamJoin.java 14KB

GroupedTableOperationRepartitionNode.java 5KB

StreamSourceNode.java 4KB

StreamStreamJoinNode.java 13KB

KTableKTableJoinNode.java 10KB

TableSourceNode.java 8KB

UnoptimizableRepartitionNode.java 4KB

GraphNode.java 5KB

BaseRepartitionNode.java 6KB

GraphGraceSearchUtil.java 5KB

ProcessorParameters.java 5KB

KTableKTableRightJoin.java 8KB

KStreamSessionWindowAggregate.java 17KB

GroupedStreamAggregateBuilder.java 6KB

KStreamImpl.java 71KB

AbstractKStreamTimeWindowAggregateProcessor.java 11KB

InternalStreamsBuilder.java 33KB

KTableImpl.java 64KB

KGroupedStream.java 38KB

Produced.java 8KB

ValueTransformerWithKey.java 6KB

TimeWindowedDeserializer.java 5KB

SessionWindowedKStream.java 48KB

Materialized.java 13KB

TimeWindowedKStream.java 47KB

Repartitioned.java 8KB

KTable.java 136KB

CogroupedKStream.java 20KB

TimeWindows.java 12KB

Consumed.java 9KB

Transformer.java 5KB

KGroupedTable.java 46KB

KeyQueryMetadata.java 4KB

StoreQueryParameters.java 5KB

RecordContext.java 5KB

ThreadMetadata.java 5KB

StreamPartitioner.java 5KB

TaskId.java 7KB

ProcessingContext.java 9KB

FixedKeyRecord.java 5KB

Record.java 7KB

ProcessorContext.java 5KB

FixedKeyProcessorContext.java 5KB

StateRestoreListener.java 5KB

ConnectedStoreProvider.java 5KB

StateStoreContext.java 5KB

WindowedChangelogTopicConfig.java 4KB

SourceNode.java 4KB

ActiveTaskCreator.java 14KB

InternalProcessorContext.java 5KB

GlobalStateUpdateTask.java 6KB

StateUpdater.java 8KB

DefaultTaskExecutor.java 6KB

DefaultTaskManager.java 9KB

ThreadMetrics.java 18KB

ProcessorNodeMetrics.java 13KB

StreamsMetricsImpl.java 42KB

TopicMetrics.java 4KB

TaskMetrics.java 19KB

GlobalStreamThread.java 18KB

StickyTaskAssignor.java 13KB

CopartitionedTopicsEnforcer.java 9KB

HighAvailabilityTaskAssignor.java 12KB

AssignorConfiguration.java 14KB

ConsumerProtocolUtils.java 5KB

ClientState.java 20KB

ClientTagAwareStandbyTaskAssignor.java 18KB

SubscriptionInfo.java 16KB

TaskMovement.java 16KB

AssignmentInfo.java 22KB

KafkaStreamsNamedTopologyWrapper.java 21KB

RemoveNamedTopologyResult.java 5KB

StandbyTaskCreator.java 7KB

TaskExecutionMetadata.java 6KB

InternalTopicManager.java 45KB

ProcessorContextImpl.java 15KB

RecordCollectorImpl.java 19KB

StreamThread.java 60KB

GlobalStateManagerImpl.java 19KB

StateDirectory.java 30KB

GlobalProcessorContextImpl.java 6KB

StoreToProcessorContextAdapter.java 5KB

StreamsProducer.java 17KB

ProcessorTopology.java 10KB

TopicPartitionMetadata.java 4KB

Tasks.java 14KB

TopologyMetadata.java 28KB

TaskManager.java 85KB

AbstractReadOnlyDecorator.java 12KB

RecordDeserializer.java 5KB

AbstractReadWriteDecorator.java 12KB

SinkNode.java 4KB

StandbyTask.java 13KB

ThreadMetadataImpl.java 5KB

VersionedChangelogTopicConfig.java 5KB

InternalTopicConfig.java 4KB

ProcessorNode.java 8KB

ForwardingDisabledProcessorContext.java 5KB

StreamTask.java 52KB

DefaultStateUpdater.java 38KB

StateManagerUtil.java 9KB

InternalTopologyBuilder.java 94KB

PartitionGrouper.java 4KB

AbstractTask.java 8KB

PartitionGroup.java 16KB

StoreChangelogReader.java 54KB

StreamsMetadataState.java 29KB

AbstractProcessorContext.java 9KB

ProcessorRecordContext.java 7KB

RepartitionTopics.java 15KB

StreamsRebalanceListener.java 6KB

ReadOnlyTask.java 7KB

ChangelogTopics.java 6KB

ClientUtils.java 11KB

ProcessorContextUtils.java 4KB

RecordQueue.java 9KB

Task.java 8KB

StreamsPartitionAssignor.java 75KB

ProcessorStateManager.java 32KB

TaskExecutor.java 14KB

ProcessorMetadata.java 5KB

ProcessorContext.java 13KB

StateStore.java 8KB

TopologyConfig.java 14KB

StreamsBuilder.java 36KB

ClientMetrics.java 6KB

StreamsConfigUtils.java 5KB

ApiUtils.java 4KB

ReadOnlySessionStore.java 22KB

QueryableStoreTypes.java 7KB

VersionedKeyValueStore.java 8KB

ValueAndTimestampSerializer.java 5KB

AbstractMergedSortedCacheStoreIterator.java 7KB

MeteredKeyValueStore.java 22KB

MergedSortedCacheWindowStoreKeyValueIterator.java 4KB

CompositeReadOnlySessionStore.java 11KB

MeteredVersionedKeyValueStore.java 12KB

RocksDBSessionStore.java 6KB

CachingWindowStore.java 25KB

WrappedStateStore.java 5KB

OffsetCheckpoint.java 9KB

AbstractRocksDBSegmentedBytesStore.java 16KB

MemoryNavigableLRUCache.java 7KB

StateStoreMetrics.java 21KB

RocksDBMetrics.java 37KB

RocksDBMetricsRecorder.java 28KB

TimeOrderedCachingWindowStore.java 32KB

RocksDBTimeOrderedSessionStore.java 7KB

PositionSerde.java 4KB

ListValueStore.java 6KB

ChangeLoggingKeyValueBytesStore.java 5KB

AbstractSegments.java 9KB

SegmentedBytesStore.java 9KB

ChangeLoggingSessionBytesStore.java 5KB

VersionedKeyValueToBytesStoreAdapter.java 7KB

MeteredWindowStore.java 20KB

InMemoryTimeOrderedKeyValueBuffer.java 23KB

ReadOnlyWindowStoreFacade.java 5KB

MeteredTimestampedKeyValueStore.java 5KB

RocksDBVersionedStoreSegmentValueFormatter.java 33KB

ThreadCache.java 13KB

PrefixedWindowKeySchemas.java 18KB

RocksDBVersionedStore.java 44KB

RocksDBStore.java 33KB

InMemoryKeyValueStore.java 9KB

NamedCache.java 12KB

KeyValueToTimestampedKeyValueByteStoreAdapter.java 6KB

RocksDbWindowBytesStoreSupplier.java 5KB

TimeOrderedKeyValueBufferChangelogDeserializationHelper.java 7KB

InMemoryWindowStore.java 26KB

RocksDBTimeOrderedWindowSegmentedBytesStore.java 6KB

LogicalKeyValueSegments.java 6KB

MemoryLRUCache.java 8KB

AbstractDualSchemaRocksDBSegmentedBytesStore.java 13KB

TimestampedKeyValueStoreBuilder.java 8KB

LogicalKeyValueSegment.java 13KB

PrefixedSessionKeySchemas.java 17KB

RocksDbIndexedTimeOrderedWindowBytesStoreSupplier.java 7KB

CachingKeyValueStore.java 20KB

WindowStoreIteratorWrapper.java 5KB

CompositeReadOnlyKeyValueStore.java 8KB

StreamsMetadataImpl.java 6KB

InMemorySessionStore.java 23KB

KeyValueStoreWrapper.java 6KB

ChangeLoggingWindowBytesStore.java 6KB

WindowToTimestampedWindowByteStoreAdapter.java 9KB

CompositeReadOnlyWindowStore.java 9KB

MeteredSessionStore.java 20KB

RocksDBTimestampedStore.java 20KB

StreamThreadStateStoreProvider.java 6KB

AbstractRocksDBTimeOrderedSegmentedBytesStore.java 12KB

Murmur3.java 17KB

LeftOrRightValue.java 4KB

RocksDBWindowStore.java 6KB

BufferValue.java 6KB

TimestampedWindowStoreBuilder.java 10KB

RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java 52KB

WindowKeySchema.java 10KB

RocksDBVersionedStoreRestoreWriteBuffer.java 11KB

SessionKeySchema.java 8KB

RocksDBTimeOrderedWindowStore.java 8KB

RocksDBTimeOrderedSessionSegmentedBytesStore.java 8KB

StoreQueryUtils.java 17KB

CachingSessionStore.java 23KB

WindowStore.java 9KB

ReadOnlyKeyValueStore.java 7KB

ReadOnlyWindowStore.java 11KB

StreamsMetadata.java 6KB

StateSerdes.java 7KB

SessionStore.java 7KB

Stores.java 33KB

Topology.java 59KB

StreamsMetrics.java 7KB

StateQueryRequest.java 7KB

QueryResult.java 6KB

StateQueryResult.java 4KB

Position.java 7KB

StreamsConfig.java 94KB

TopologyDescription.java 6KB

KafkaStreams.java 97KB

StreamsUpgradeTest.java 4KB

StreamsSmokeTest.java 4KB

SmokeTestDriver.java 29KB

StreamsUpgradeTest.java 5KB

SmokeTestUtil.java 5KB

SmokeTestClient.java 12KB

DeveloperGuideTesting.java 7KB

WordCountDemoTest.java 5KB

WordCountTransformerTest.java 4KB

TemperatureDemo.java 6KB

PageViewTypedDemo.java 10KB

PageViewUntypedDemo.java 6KB

WordCountTransformerDemo.java 7KB

WordCountDemo.java 5KB

WordCountProcessorDemo.java 6KB

StreamsSmokeTest.java 4KB

SmokeTestDriver.java 29KB

StreamsUpgradeTest.java 5KB

SmokeTestUtil.java 5KB

SmokeTestClient.java 12KB

StreamsUpgradeToCooperativeRebalanceTest.java 6KB

StreamsSmokeTest.java 4KB

SmokeTestDriver.java 29KB

StreamsUpgradeTest.java 5KB

SmokeTestUtil.java 5KB

SmokeTestClient.java 12KB

StreamsSmokeTest.java 4KB

SmokeTestDriver.java 29KB

StreamsUpgradeTest.java 5KB

SmokeTestUtil.java 5KB

SmokeTestClient.java 12KB

StreamsSmokeTest.java 4KB

SmokeTestDriver.java 29KB

StreamsUpgradeTest.java 5KB

SmokeTestUtil.java 5KB

SmokeTestClient.java 12KB

StreamsSmokeTest.java 4KB

SmokeTestDriver.java 27KB

SmokeTestUtil.java 5KB

StreamsUpgradeToCooperativeRebalanceTest.java 6KB

SmokeTestClient.java 12KB

StreamsUpgradeToCooperativeRebalanceTest.java 6KB

StreamsSmokeTest.java 4KB

SmokeTestDriver.java 29KB

StreamsUpgradeTest.java 5KB

SmokeTestUtil.java 5KB

SmokeTestClient.java 12KB

StreamsSmokeTest.java 4KB

SmokeTestDriver.java 29KB

StreamsUpgradeTest.java 5KB

SmokeTestUtil.java 5KB

SmokeTestClient.java 12KB

StreamsUpgradeToCooperativeRebalanceTest.java 6KB

StreamsSmokeTest.java 4KB

SmokeTestDriver.java 29KB

StreamsUpgradeTest.java 5KB

SmokeTestUtil.java 5KB

SmokeTestClient.java 12KB

StreamsUpgradeTest.java 4KB

TopologyTestDriverTest.java 78KB

WindowStoreFacadeTest.java 4KB

MockProcessorContextTest.java 15KB

KeyValueStoreFacadeTest.java 6KB

MockProcessorContextAPITest.java 15KB

TestRecordTest.java 8KB

WindowedWordCountProcessorTest.java 7KB

MockProcessorContextStateStoreTest.java 9KB

TestTopicsTest.java 22KB

MockProcessorContext.java 19KB

MockProcessorContext.java 21KB

TestOutputTopic.java 7KB

TopologyTestDriver.java 63KB

TestInputTopic.java 11KB

TestRecord.java 7KB

StreamsSmokeTest.java 4KB

SmokeTestDriver.java 27KB

SmokeTestUtil.java 5KB

StreamsUpgradeToCooperativeRebalanceTest.java 6KB

SmokeTestClient.java 12KB

AgentTest.java 21KB

RestExceptionMapperTest.java 4KB

CoordinatorTest.java 32KB

ExternalCommandWorkerTest.java 8KB

PayloadGeneratorTest.java 10KB

ExpectedTasks.java 8KB

MiniTrogdorCluster.java 11KB

WorkerUtilsTest.java 14KB

Agent.java 10KB

AgentClient.java 13KB

WorkerManager.java 24KB

Kibosh.java 7KB

DegradedNetworkFaultWorker.java 8KB

BasicPlatform.java 4KB

TasksRequest.java 4KB

JsonRestServer.java 12KB

NodeManager.java 14KB

CoordinatorRestResource.java 6KB

TaskManager.java 26KB

CoordinatorClient.java 22KB

Coordinator.java 7KB

RoundTripWorkloadSpec.java 5KB

ProduceBenchSpec.java 7KB

TimestampRecordProcessor.java 6KB

ConfigurableProducerSpec.java 9KB

RoundTripWorker.java 19KB

PartitionsSpec.java 5KB

GaussianTimestampConstantPayloadGenerator.java 5KB

ConsumeBenchSpec.java 10KB

GaussianTimestampRandomPayloadGenerator.java 5KB

SustainedConnectionWorker.java 23KB

ConfigurableProducerWorker.java 12KB

Histogram.java 7KB

ConnectionStressWorker.java 12KB

SustainedConnectionSpec.java 7KB

ConsumeBenchWorker.java 23KB

GaussianThroughputGenerator.java 6KB

ExternalCommandWorker.java 15KB

ProduceBenchWorker.java 17KB

WorkerUtils.java 17KB

StringFormatter.java 4KB

FetchSessionBenchmark.java 5KB

BaseRecordBatchBenchmark.java 6KB

GetListOffsetsCallsBenchmark.java 6KB

AuthorizerBenchmark.java 12KB

PartitionMakeFollowerBenchmark.java 7KB

UpdateFollowerFetchStateBenchmark.java 8KB

MetadataRequestBenchmark.java 11KB

ReplicaFetcherThreadBenchmark.java 17KB

FetchResponseBenchmark.java 5KB

FetchRequestBenchmark.java 5KB

CheckpointBench.java 7KB

PartitionCreationBench.java 9KB

README.md 6KB

KafkaLog4jAppenderTest.java 9KB

KafkaLog4jAppender.java 13KB

README.md 12KB

EventAccumulatorTest.java 8KB

GroupCoordinator.java 12KB

EventAccumulator.java 7KB

AclsDeltaTest.java 5KB

TopicsImageTest.java 17KB

ClientQuotasImageTest.java 5KB

ConfigurationsImageTest.java 5KB

ImageDowngradeTest.java 6KB

ClusterImageTest.java 6KB

FeaturesImageTest.java 4KB

MetadataLoaderTest.java 24KB

ScramImageTest.java 6KB

SnapshotGeneratorTest.java 8KB

SnapshotEmitterTest.java 6KB

MetadataNodeRedactionCriteriaTest.java 4KB

ClientQuotasImageNodeTest.java 5KB

QuorumControllerTest.java 77KB

QuorumFeaturesTest.java 7KB

ControllerPurgatoryTest.java 4KB

BrokerHeartbeatManagerTest.java 14KB

QuorumControllerMetricsTest.java 6KB

ControllerMetadataMetricsPublisherTest.java 7KB

ControllerMetricsChangesTest.java 8KB

ControllerMetadataMetricsTest.java 7KB

ClientQuotaControlManagerTest.java 23KB

ProducerIdControlManagerTest.java 6KB

ConfigurationControlManagerTest.java 18KB

ClusterControlManagerTest.java 26KB

PartitionChangeBuilderTest.java 23KB

FeatureControlManagerTest.java 23KB

BrokersToIsrsTest.java 5KB

ReplicationControlManagerTest.java 135KB

PartitionReassignmentReplicasTest.java 8KB

QuorumControllerTestEnv.java 7KB

AclControlManagerTest.java 16KB

MetadataRecordSerdeTest.java 9KB

ReplicasTest.java 5KB

KRaftMigrationZkWriterTest.java 9KB

KRaftMigrationDriverTest.java 28KB

CapturingMigrationClient.java 5KB

KafkaConfigSchemaTest.java 8KB

ScramCredentialDataTest.java 4KB

PartitionRegistrationTest.java 9KB

BootstrapDirectoryTest.java 5KB

BootstrapMetadataTest.java 4KB

BrokerRegistrationTest.java 7KB

StripedReplicaPlacerTest.java 14KB

RecordTestUtils.java 9KB

StandardAuthorizerPropertyTest.java 11KB

StandardAuthorizerTest.java 35KB

ClusterMetadataAuthorizerTest.java 10KB

StandardAclTest.java 4KB

MockAuthorizableRequestContext.java 5KB

BatchFileWriterReaderTest.java 5KB

RecordRedactorTest.java 4KB

LocalLogManager.java 33KB

LocalLogManagerTest.java 7KB

LocalLogManagerTestEnv.java 8KB

MockMetaLogManagerListener.java 5KB

FeaturesImage.java 6KB

MetadataDelta.java 14KB

MetadataImage.java 5KB

AclsDelta.java 5KB

ClusterDelta.java 6KB

MetadataLoader.java 26KB

ConfigurationsDelta.java 4KB

FeaturesDelta.java 4KB

TopicDelta.java 7KB

TopicsDelta.java 8KB

SnapshotGenerator.java 10KB

SnapshotEmitter.java 4KB

ClientQuotasImageNode.java 5KB

ClientQuotasImage.java 8KB

ScramImage.java 7KB

ScramDelta.java 4KB

ClientQuotaControlManager.java 13KB

FeatureControlManager.java 15KB

QuorumControllerMetrics.java 7KB

ControllerMetadataMetrics.java 8KB

ControllerMetadataMetricsPublisher.java 7KB

ControllerMetricsChanges.java 5KB

BrokerHeartbeatManager.java 22KB

ConfigurationControlManager.java 22KB

ReplicationControlManager.java 96KB

ClusterControlManager.java 24KB

ControllerPurgatory.java 4KB

QuorumFeatures.java 7KB

Controller.java 13KB

PartitionChangeBuilder.java 13KB

AclControlManager.java 10KB

PartitionReassignmentReplicas.java 5KB

BrokersToIsrs.java 11KB

QuorumController.java 100KB

ScramControlManager.java 14KB

BrokerRegistration.java 12KB

ZkMigrationLeadershipState.java 7KB

KRaftMigrationZkWriter.java 33KB

KRaftMigrationDriver.java 34KB

MigrationDriverState.java 4KB

BootstrapMetadata.java 5KB

BootstrapDirectory.java 5KB

KafkaConfigSchema.java 11KB

StripedReplicaPlacer.java 17KB

PartitionRegistration.java 10KB

ClusterMetadataAuthorizer.java 7KB

StandardAcl.java 7KB

StandardAuthorizerData.java 25KB

StandardAuthorizer.java 9KB

Replicas.java 8KB

SnapshotFileReader.java 8KB

BatchFileWriter.java 4KB

BatchFileReader.java 7KB

ExactlyOnceMessageProcessor.java 9KB

Consumer.java 5KB

KafkaExactlyOnceDemo.java 8KB

Producer.java 6KB

LsCommandHandlerTest.java 4KB

GlobVisitorTest.java 7KB

Commands.java 6KB

CommandUtils.java 6KB

CatCommandHandler.java 4KB

FindCommandHandler.java 4KB

LsCommandHandler.java 11KB

MetadataShell.java 8KB

InteractiveShell.java 6KB

GlobComponent.java 6KB

GlobVisitor.java 6KB

introduction.html 13KB

ecosystem.html 1KB

core-concepts.html 899B

architecture.html 898B

tutorial.html 894B

quickstart.html 896B

index.html 891B

app-reset-tool.html 919B

dsl-api.html 912B

manage-topics.html 918B

datatypes.html 914B

dsl-topology-naming.html 924B

testing.html 912B

interactive-queries.html 924B

running-app.html 916B

write-streams.html 918B

index.html 910B

config-streams.html 919B

memory-mgmt.html 916B

security.html 913B

processor-api.html 918B

upgrade-guide.html 899B

index.html 824B

core-concepts.html 31KB

architecture.html 14KB

tutorial.html 31KB

quickstart.html 19KB

index.html 23KB

app-reset-tool.html 14KB

dsl-api.html 320KB

manage-topics.html 9KB

datatypes.html 17KB

dsl-topology-naming.html 15KB

testing.html 20KB

interactive-queries.html 41KB

running-app.html 18KB

write-streams.html 16KB

index.html 5KB

config-streams.html 89KB

memory-mgmt.html 25KB

security.html 15KB

processor-api.html 60KB

upgrade-guide.html 107KB

protocol.html 22KB

toc.html 13KB

configuration.html 19KB

documentation.html 6KB

api.html 6KB

migration.html 2KB

upgrade.html 197KB

ops.html 216KB

uses.html 6KB

quickstart.html 18KB

implementation.html 25KB

design.html 74KB

security.html 168KB

connect.html 78KB

ProducerConfigTest.java 5KB

KafkaProducerTest.java 110KB

MockProducerTest.java 29KB

RoundRobinPartitionerTest.java 6KB

BuiltInPartitionerTest.java 10KB

ProducerInterceptorsTest.java 10KB

TransactionManagerTest.java 175KB

ProducerBatchTest.java 13KB

SenderTest.java 158KB

KafkaProducerMetricsTest.java 4KB

RecordAccumulatorTest.java 72KB

BufferPoolTest.java 17KB

ProducerMetadataTest.java 14KB

StickyPartitionCacheTest.java 5KB

RecordSendTest.java 4KB

UniformStickyPartitionerTest.java 9KB

ClusterConnectionStatesTest.java 22KB

KafkaAdminClientTest.java 357KB

ListTransactionsResultTest.java 5KB

AdminClientUnitTestEnv.java 5KB

ListConsumerGroupOffsetsHandlerTest.java 22KB

AbortTransactionHandlerTest.java 11KB

AdminMetadataManagerTest.java 4KB

PartitionLeaderStrategyTest.java 12KB

RemoveMembersFromConsumerGroupHandlerTest.java 8KB

CoordinatorStrategyTest.java 13KB

FenceProducersHandlerTest.java 6KB

AdminApiDriverTest.java 29KB

AlterConsumerGroupOffsetsHandlerTest.java 8KB

DeleteConsumerGroupsHandlerTest.java 6KB

DeleteConsumerGroupOffsetsHandlerTest.java 10KB

ListTransactionsHandlerTest.java 9KB

DescribeConsumerGroupsHandlerTest.java 9KB

AllBrokersStrategyTest.java 5KB

AllBrokersStrategyIntegrationTest.java 11KB

DescribeTransactionsHandlerTest.java 10KB

DescribeProducersHandlerTest.java 14KB

MemberDescriptionTest.java 5KB

DescribeUserScramCredentialsResultTest.java 6KB

MockAdminClient.java 57KB

RemoveMembersFromConsumerGroupResultTest.java 5KB

DeleteConsumerGroupOffsetsResultTest.java 5KB

AdminClientTestUtils.java 8KB

FetchSessionHandlerTest.java 42KB

CommonClientConfigsTest.java 7KB

NodeApiVersionsTest.java 8KB

ClientUtilsTest.java 5KB

StickyAssignorTest.java 22KB

RangeAssignorTest.java 33KB

MockConsumerTest.java 7KB

ConsumerConfigTest.java 7KB

ConsumerMetadataTest.java 9KB

CoordinatorRequestManagerTest.java 8KB

FetchConfigTest.java 4KB

RequestFutureTest.java 8KB

NetworkClientDelegateTest.java 6KB

SubscriptionStateTest.java 36KB

AbstractPartitionAssignorTest.java 16KB

ConsumerCoordinatorTest.java 194KB

ConsumerInterceptorsTest.java 9KB

PrototypeAsyncConsumerTest.java 9KB

ConsumerNetworkClientTest.java 17KB

FetcherTest.java 164KB

HeartbeatTest.java 5KB

DefaultBackgroundThreadTest.java 8KB

FetchMetricsManagerTest.java 7KB

OffsetFetcherTest.java 79KB

AbstractCoordinatorTest.java 74KB

OffsetForLeaderEpochClientTest.java 8KB

CommitRequestManagerTest.java 17KB

CompletedFetchTest.java 13KB

AbstractStickyAssignorTest.java 76KB

ConsumerProtocolTest.java 14KB

TopicMetadataFetcherTest.java 11KB

ConsumerRecordTest.java 5KB

RoundRobinAssignorTest.java 16KB

KafkaConsumerTest.java 140KB

CooperativeStickyAssignorTest.java 16KB

ConsumerPartitionAssignorTest.java 5KB

NetworkClientTest.java 56KB

MockClient.java 30KB

MetadataTest.java 55KB

InFlightRequestsTest.java 5KB

ListDeserializerTest.java 13KB

SerializationTest.java 19KB

ListSerializerTest.java 8KB

FeaturesTest.java 6KB

SupportedVersionRangeTest.java 6KB

MessageTest.java 59KB

SimpleExampleMessageTest.java 16KB

ApiMessageTypeTest.java 5KB

NullableStructMessageTest.java 4KB

DefaultRecordBatchTest.java 20KB

DefaultRecordTest.java 20KB

LegacyRecordTest.java 6KB

RemoteLogInputStreamTest.java 13KB

FileLogInputStreamTest.java 15KB

FileRecordsTest.java 33KB

ByteBufferLogInputStreamTest.java 5KB

LazyDownConversionRecordsTest.java 12KB

MemoryRecordsTest.java 51KB

MemoryRecordsBuilderTest.java 41KB

AbstractLegacyRecordBatchTest.java 12KB

SendBuilderTest.java 6KB

MessageUtilTest.java 5KB

RawTaggedFieldWriterTest.java 4KB

ProtocolSerializationTest.java 21KB

KafkaMbeanTest.java 6KB

MetricsTest.java 42KB

JmxReporterTest.java 9KB

FrequenciesTest.java 6KB

HistogramTest.java 9KB

SensorTest.java 16KB

KerberosNameTest.java 5KB

SaslAuthenticatorFailureDelayTest.java 11KB

SaslAuthenticatorTest.java 132KB

ClientAuthenticationFailureTest.java 7KB

LoginManagerTest.java 9KB

SaslServerAuthenticatorTest.java 19KB

TestJaasConfig.java 7KB

TestKeyManagerFactory.java 4KB

SslFactoryTest.java 29KB

SslPrincipalMapperTest.java 6KB

DefaultSslEngineFactoryTest.java 19KB

OAuthBearerLoginModuleTest.java 21KB

OAuthBearerLoginCallbackHandlerTest.java 11KB

OAuthBearerValidatorCallbackHandlerTest.java 5KB

ExpiringCredentialRefreshingLoginTest.java 36KB

OAuthBearerSaslClientTest.java 6KB

OAuthBearerSaslServerTest.java 11KB

OAuthBearerClientInitialResponseTest.java 6KB

AccessTokenBuilder.java 6KB

HttpAccessTokenRetrieverTest.java 11KB

ConfigurationUtilsTest.java 5KB

RetryTest.java 5KB

OAuthBearerTest.java 8KB

ClaimValidationUtilsTest.java 6KB

RefreshingHttpsJwksTest.java 7KB

AccessTokenValidatorTest.java 4KB

OAuthBearerValidationUtilsTest.java 13KB

OAuthBearerUnsecuredJwsTest.java 8KB

OAuthBearerUnsecuredLoginCallbackHandlerTest.java 8KB

OAuthBearerUnsecuredValidatorCallbackHandlerTest.java 9KB

JaasContextTest.java 16KB

PlainSaslServerTest.java 5KB

ScramMessagesTest.java 15KB

ScramFormatterTest.java 5KB

ScramCredentialUtilsTest.java 5KB

DefaultKafkaPrincipalBuilderTest.java 8KB

AclOperationTest.java 4KB

ResourcePatternFilterTest.java 7KB

AclBindingTest.java 6KB

KafkaFutureTest.java 28KB

ConfigUtilsTest.java 7KB

UtilsTest.java 39KB

MockScheduler.java 4KB

FlattenedIteratorTest.java 4KB

SecurityUtilsTest.java 5KB

ByteUtilsTest.java 17KB

TimerTest.java 5KB

ImplicitLinkedHashMultiCollectionTest.java 7KB

ImplicitLinkedHashCollectionTest.java 24KB

LogCaptureAppender.java 4KB

RecordHeadersTest.java 8KB

PartitionStatesTest.java 9KB

TopicTest.java 4KB

LeaderAndIsrResponseTest.java 8KB

DescribeAclsResponseTest.java 7KB

StopReplicaResponseTest.java 5KB

UpdateMetadataRequestTest.java 10KB

DeleteTopicsRequestTest.java 7KB

OffsetCommitRequestTest.java 6KB

DeleteAclsRequestTest.java 5KB

ListOffsetsRequestTest.java 7KB

CreateAclsRequestTest.java 5KB

StopReplicaRequestTest.java 11KB

RequestContextTest.java 9KB

ProduceRequestTest.java 17KB

AlterReplicaLogDirsRequestTest.java 5KB

LeaveGroupResponseTest.java 8KB

OffsetCommitResponseTest.java 4KB

ProduceResponseTest.java 7KB

AddPartitionsToTxnResponseTest.java 7KB

LeaderAndIsrRequestTest.java 10KB

RequestHeaderTest.java 6KB

UpdateFeaturesRequestTest.java 6KB

LeaveGroupRequestTest.java 5KB

AddPartitionsToTxnRequestTest.java 8KB

RequestTestUtils.java 16KB

ApiVersionsResponseTest.java 12KB

DeleteAclsResponseTest.java 5KB

RequestResponseTest.java 183KB

OffsetFetchResponseTest.java 21KB

FetchRequestTest.java 13KB

DescribeAclsRequestTest.java 5KB

OffsetFetchRequestTest.java 11KB

MetadataRequestTest.java 5KB

TxnOffsetCommitRequestTest.java 5KB

ClusterTest.java 4KB

KafkaChannelTest.java 5KB

NetworkTestUtils.java 7KB

SaslChannelBuilderTest.java 11KB

EchoServer.java 5KB

SslTransportTls12Tls13Test.java 8KB

SelectorTest.java 50KB

SslSelectorTest.java 17KB

SslVersionsTransportLayerTest.java 9KB

SslTransportLayerTest.java 72KB

CertStores.java 6KB

NioEchoServer.java 16KB

ChannelBuildersTest.java 6KB

GarbageCollectedMemoryPoolTest.java 6KB

KafkaLZ4Test.java 14KB

AbstractConfigTest.java 32KB

ConfigDefTest.java 35KB

EnvVarConfigProviderTest.java 4KB

DirectoryConfigProviderTest.java 6KB

ConfigTransformerTest.java 6KB

SaslConfigsTest.java 6KB

Microbenchmarks.java 7KB

TestSslUtils.java 29KB

TestUtils.java 25KB

MockProducerInterceptor.java 5KB

MockSelector.java 7KB

MockConsumerInterceptor.java 5KB

README.md 12KB

CommonClientConfigs.java 21KB

RecordMetadata.java 5KB

ProducerConfig.java 45KB

ProducerRecord.java 9KB

ProducerBatch.java 22KB

ProducerMetadata.java 6KB

FutureRecordMetadata.java 4KB

ProduceRequestResult.java 4KB

ProducerInterceptors.java 7KB

TransactionManager.java 77KB

BuiltInPartitioner.java 17KB

SenderMetricsRegistry.java 10KB

BufferPool.java 15KB

RecordAccumulator.java 58KB

Sender.java 50KB

KafkaProducerMetrics.java 5KB

MockProducer.java 20KB

ProducerInterceptor.java 6KB

KafkaProducer.java 87KB

NetworkClientUtils.java 5KB

FetchSessionHandler.java 27KB

NetworkClient.java 58KB

RemoveMembersFromConsumerGroupResult.java 5KB

DescribeTopicsResult.java 6KB

ListConsumerGroupsResult.java 4KB

NewTopic.java 7KB

CreateTopicsResult.java 6KB

ListOffsetsResult.java 4KB

QuorumInfo.java 6KB

Admin.java 78KB

KafkaAdminClient.java 229KB

DescribeLogDirsResult.java 5KB

FeatureUpdate.java 5KB

DescribeUserScramCredentialsResult.java 8KB

AdminApiLookupStrategy.java 5KB

DeleteConsumerGroupOffsetsHandler.java 7KB

ListConsumerGroupOffsetsHandler.java 9KB

AdminApiHandler.java 7KB

PartitionLeaderStrategy.java 8KB

AbortTransactionHandler.java 9KB

DeleteConsumerGroupsHandler.java 6KB

AdminApiDriver.java 18KB

DescribeTransactionsHandler.java 8KB

DescribeConsumerGroupsHandler.java 9KB

AdminApiFuture.java 4KB

AdminMetadataManager.java 8KB

FenceProducersHandler.java 7KB

AllBrokersStrategy.java 8KB

RemoveMembersFromConsumerGroupHandler.java 6KB

DescribeProducersHandler.java 9KB

AlterConsumerGroupOffsetsHandler.java 8KB

CoordinatorStrategy.java 8KB

ListTransactionsHandler.java 6KB

ConsumerGroupDescription.java 5KB

ListTransactionsResult.java 5KB

DeleteAclsResult.java 4KB

AdminClientConfig.java 14KB

ConfigEntry.java 9KB

DescribeReplicaLogDirsResult.java 6KB

ForwardingAdmin.java 11KB

ListConsumerGroupOffsetsResult.java 4KB

FeatureMetadata.java 4KB

TopicDescription.java 5KB

GroupRebalanceConfig.java 4KB

NodeApiVersions.java 10KB

ConsumerRebalanceListener.java 14KB

CooperativeStickyAssignor.java 7KB

OffsetAndMetadata.java 4KB

RangeAssignor.java 16KB

RoundRobinAssignor.java 7KB

ConsumerConfig.java 39KB

MockConsumer.java 20KB

Consumer.java 7KB

StickyAssignor.java 13KB

DefaultBackgroundThread.java 10KB

NetworkClientDelegate.java 10KB

SubscriptionState.java 47KB

Fetcher.java 5KB

RequestFuture.java 9KB

ConsumerProtocol.java 9KB

DefaultEventHandler.java 9KB

TopicMetadataFetcher.java 7KB

AbstractStickyAssignor.java 80KB

FetchMetricsRegistry.java 9KB

AbstractPartitionAssignor.java 8KB

RequestState.java 4KB

PrototypeAsyncConsumer.java 24KB

Heartbeat.java 4KB

CommitRequestManager.java 24KB

CompletedFetch.java 16KB

FetchMetricsManager.java 9KB

Fetch.java 5KB

AbstractFetch.java 38KB

ConsumerCoordinator.java 85KB

ApplicationEventProcessor.java 5KB

CoordinatorRequestManager.java 10KB

FetchConfig.java 6KB

OffsetsForLeaderEpochClient.java 7KB

OffsetFetcher.java 37KB

ConsumerNetworkClient.java 29KB

AbstractCoordinator.java 79KB

ConsumerInterceptors.java 4KB

KafkaConsumerMetrics.java 5KB

ConsumerPartitionAssignor.java 13KB

ConsumerRecords.java 5KB

ConsumerInterceptor.java 5KB

ConsumerRecord.java 12KB

KafkaConsumer.java 148KB

KafkaClient.java 8KB

ClientResponse.java 7KB

ClusterConnectionStates.java 21KB

ClientRequest.java 4KB

MetadataCache.java 10KB

ClientUtils.java 6KB

InFlightRequests.java 7KB

Metadata.java 27KB

ListSerializer.java 6KB

ListDeserializer.java 10KB

Serdes.java 9KB

BaseVersionRange.java 5KB

Features.java 5KB

LazyDownConversionRecordsSend.java 5KB

FileLogInputStream.java 9KB

LegacyRecord.java 22KB

MultiRecordsSend.java 5KB

CompressionRatioEstimator.java 5KB

DefaultRecordBatch.java 30KB

Records.java 5KB

RecordsUtil.java 7KB

MemoryRecordsBuilder.java 38KB

RecordBatch.java 9KB

DefaultRecord.java 24KB

MemoryRecords.java 41KB

AbstractLegacyRecordBatch.java 20KB

ControlRecordType.java 4KB

EndTransactionMarker.java 5KB

AbstractRecords.java 6KB

FileRecords.java 22KB

CompressionType.java 8KB

LazyDownConversionRecords.java 9KB

ApiKeys.java 14KB

MessageUtil.java 8KB

SendBuilder.java 7KB

Errors.java 32KB

Type.java 36KB

CompactArrayOf.java 4KB

Struct.java 18KB

Schema.java 8KB

TaggedFields.java 7KB

Field.java 7KB

Protocol.java 7KB

Sensor.java 15KB

SampledStat.java 5KB

Rate.java 4KB

Histogram.java 7KB

TokenBucket.java 4KB

Frequencies.java 8KB

Percentiles.java 5KB

Metrics.java 31KB

JmxReporter.java 13KB

IntGaugeSuite.java 10KB

KerberosRule.java 7KB

KerberosLogin.java 19KB

KerberosError.java 5KB

KerberosShortNamer.java 4KB

SaslClientCallbackHandler.java 5KB

DefaultKafkaPrincipalBuilder.java 6KB

AbstractLogin.java 4KB

SaslClientAuthenticator.java 35KB

SaslServerAuthenticator.java 38KB

LoginManager.java 11KB

DefaultSslEngineFactory.java 25KB

SslPrincipalMapper.java 8KB

SslFactory.java 23KB

DelegationTokenCache.java 5KB

TokenInformation.java 4KB

JaasConfig.java 5KB

OAuthBearerValidatorCallback.java 6KB

OAuthBearerValidatorCallbackHandler.java 12KB

OAuthBearerToken.java 4KB

OAuthBearerLoginModule.java 19KB

OAuthBearerRefreshingLogin.java 7KB

ExpiringCredentialRefreshingLogin.java 23KB

ExpiringCredentialRefreshConfig.java 6KB

OAuthBearerSaslClient.java 8KB

BasicOAuthBearerToken.java 6KB

RefreshingHttpsJwksVerificationKeyResolver.java 6KB

HttpAccessTokenRetriever.java 17KB

ValidatorAccessTokenValidator.java 9KB

JwksFileVerificationKeyResolver.java 4KB

ConfigurationUtils.java 7KB

RefreshingHttpsJwks.java 14KB

ClaimValidationUtils.java 6KB

JaasOptionsUtils.java 4KB

LoginAccessTokenValidator.java 6KB

OAuthBearerSaslClientCallbackHandler.java 7KB

OAuthBearerClientInitialResponse.java 8KB

OAuthBearerSaslServer.java 11KB

OAuthBearerValidationResult.java 4KB

OAuthBearerUnsecuredLoginCallbackHandler.java 16KB

OAuthBearerValidationUtils.java 10KB

OAuthBearerUnsecuredValidatorCallbackHandler.java 10KB

OAuthBearerUnsecuredJws.java 15KB

OAuthBearerExtensionsValidatorCallback.java 5KB

OAuthBearerLoginCallbackHandler.java 12KB

OAuthBearerTokenCallback.java 4KB

JaasContext.java 10KB

PlainSaslServer.java 8KB

ScramMessages.java 11KB

ScramFormatter.java 8KB

ScramSaslServer.java 13KB

ScramSaslClient.java 11KB

KafkaPrincipal.java 4KB

SaslExtensions.java 4KB

SslEngineFactory.java 4KB

ClusterResourceListener.java 4KB

AclOperation.java 4KB

AccessControlEntryFilter.java 4KB

PatternType.java 4KB

ResourcePatternFilter.java 6KB

ByteBufferOutputStream.java 5KB

Utils.java 58KB

SecurityUtils.java 7KB

PureJavaCrc32C.java 33KB

ChildFirstClassLoader.java 5KB

Bytes.java 6KB

ByteBufferUnmapper.java 6KB

ImplicitLinkedHashMultiCollection.java 5KB

ImplicitLinkedHashCollection.java 23KB

BufferSupplier.java 4KB

ByteUtils.java 17KB

ConfigUtils.java 7KB

AppInfoParser.java 5KB

Checksums.java 5KB

LoggingSignalHandler.java 5KB

Shell.java 10KB

Timer.java 8KB

Time.java 4KB

LogContext.java 24KB

RecordHeaders.java 6KB

KafkaFutureImpl.java 10KB

Topic.java 5KB

PartitionStates.java 7KB

JoinGroupRequest.java 5KB

TxnOffsetCommitRequest.java 10KB

AddPartitionsToTxnResponse.java 7KB

AlterClientQuotasRequest.java 6KB

FetchResponse.java 14KB

UpdateMetadataRequest.java 11KB

WriteTxnMarkersResponse.java 6KB

ElectLeadersRequest.java 5KB

OffsetDeleteResponse.java 6KB

ListOffsetsRequest.java 8KB

ListOffsetsResponse.java 5KB

StopReplicaRequest.java 10KB

MetadataResponse.java 20KB

RequestHeader.java 7KB

ProduceResponse.java 9KB

AlterClientQuotasResponse.java 5KB

OffsetFetchResponse.java 18KB

FetchMetadata.java 5KB

DeleteTopicsRequest.java 4KB

LeaveGroupResponse.java 6KB

LeaderAndIsrRequest.java 9KB

FindCoordinatorRequest.java 5KB

AbstractRequest.java 13KB

VoteRequest.java 4KB

DescribeDelegationTokenResponse.java 5KB

ApiVersionsResponse.java 14KB

AbstractResponse.java 13KB

DescribeConfigsResponse.java 10KB

OffsetCommitResponse.java 7KB

FetchSnapshotResponse.java 5KB

DescribeGroupsResponse.java 5KB

DescribeQuorumRequest.java 4KB

AddPartitionsToTxnRequest.java 9KB

IncrementalAlterConfigsRequest.java 5KB

AlterPartitionRequest.java 4KB

LeaderAndIsrResponse.java 4KB

FetchRequest.java 22KB

CreateTopicsRequest.java 4KB

DescribeClientQuotasRequest.java 5KB

DeleteAclsRequest.java 6KB

DescribeClientQuotasResponse.java 5KB

ProduceRequest.java 11KB

OffsetCommitRequest.java 5KB

DeleteAclsResponse.java 6KB

DescribeAclsRequest.java 5KB

TxnOffsetCommitResponse.java 8KB

ApiVersionsRequest.java 5KB

CreateAclsRequest.java 6KB

OffsetsForLeaderEpochRequest.java 6KB

DescribeLogDirsResponse.java 5KB

LeaveGroupRequest.java 5KB

ResponseHeader.java 5KB

MetadataRequest.java 8KB

AlterPartitionReassignmentsRequest.java 4KB

UpdateFeaturesRequest.java 4KB

FetchSnapshotRequest.java 5KB

WriteTxnMarkersRequest.java 8KB

DescribeAclsResponse.java 7KB

AlterConfigsRequest.java 5KB

RequestContext.java 7KB

OffsetFetchRequest.java 16KB

EndQuorumEpochRequest.java 4KB

FindCoordinatorResponse.java 6KB

KafkaFuture.java 9KB

Authenticator.java 7KB

KafkaChannel.java 28KB

Selector.java 70KB

PlaintextTransportLayer.java 7KB

PlaintextChannelBuilder.java 5KB

ChannelBuilders.java 14KB

ReauthenticationContext.java 4KB

SaslChannelBuilder.java 20KB

SslChannelBuilder.java 7KB

NetworkReceive.java 5KB

ChannelState.java 5KB

SslTransportLayer.java 46KB

SimpleMemoryPool.java 6KB

GarbageCollectedMemoryPool.java 7KB

Uuid.java 6KB

MetricNameTemplate.java 4KB

KafkaLZ4BlockInputStream.java 12KB

KafkaLZ4BlockOutputStream.java 14KB

MetricName.java 5KB

AbstractConfig.java 29KB

SaslConfigs.java 22KB

DirectoryConfigProvider.java 4KB

EnvVarConfigProvider.java 4KB

QuotaConfigs.java 5KB

BrokerSecurityConfigs.java 7KB

ConfigTransformer.java 8KB

TopicConfig.java 15KB

SslConfigs.java 13KB

ConfigDef.java 68KB

Cluster.java 16KB

CreateTopicPolicy.java 6KB

Action.java 5KB

Authorizer.java 15KB

ClientQuotaCallback.java 5KB

RemoteLogSegmentLifecycleTest.java 30KB

TopicBasedRemoteLogMetadataManagerRestartTest.java 10KB

TopicBasedRemoteLogMetadataManagerWrapperWithHarness.java 5KB

RemoteLogMetadataSerdeTest.java 5KB

FileBasedRemoteLogMetadataCacheTest.java 5KB

TopicBasedRemoteLogMetadataManagerConfigTest.java 8KB

TopicBasedRemoteLogMetadataManagerHarness.java 7KB

RemoteLogMetadataCacheTest.java 5KB

TopicBasedRemoteLogMetadataManagerTest.java 9KB

RemoteLogMetadataTransformTest.java 5KB

InmemoryRemoteStorageManager.java 9KB

InmemoryRemoteLogMetadataManager.java 8KB

InmemoryRemoteStorageManagerTest.java 12KB

RemoteLogManagerConfigTest.java 5KB

RemoteLogMetadataManagerTest.java 9KB

LeaderEpochFileCache.java 17KB

OffsetIndex.java 10KB

LogValidator.java 32KB

ProducerStateEntry.java 7KB

ProducerAppendInfo.java 12KB

SkimpyOffsetMap.java 8KB

TimeIndex.java 12KB

LogFileUtils.java 7KB

LogConfig.java 26KB

TransactionIndex.java 10KB

ProducerStateManager.java 32KB

AbstractIndex.java 21KB

LogOffsetMetadata.java 4KB

LazyIndex.java 7KB

LogAppendInfo.java 14KB

RemoteLogSegmentMetadataSnapshotTransform.java 4KB

RemoteLogSegmentMetadataTransform.java 6KB

RemoteLogMetadataSerde.java 7KB

RemotePartitionMetadataStore.java 9KB

FileBasedRemoteLogMetadataCache.java 6KB

RemoteLogMetadataCache.java 18KB

RemoteLogMetadataSnapshotFile.java 12KB

TopicBasedRemoteLogMetadataManager.java 23KB

RemoteLogSegmentMetadataSnapshot.java 8KB

ConsumerTask.java 18KB

ProducerManager.java 5KB

RemoteLogLeaderEpochState.java 8KB

ConsumerManager.java 7KB

TopicBasedRemoteLogMetadataManagerConfig.java 13KB

ClassLoaderAwareRemoteLogMetadataManager.java 5KB

RemoteLogManagerConfig.java 25KB

LogSegmentData.java 5KB

RemoteLogMetadataManager.java 12KB

RemoteLogSegmentState.java 4KB

RemoteLogSegmentMetadata.java 10KB

RemoteStorageManager.java 7KB

RemotePartitionDeleteState.java 4KB

ClusterInstance.java 5KB

ClusterTestExtensions.java 9KB

RaftClusterInvocationContext.java 12KB

README.md 5KB

ZkClusterInvocationContext.java 13KB

ClusterConfig.java 8KB

ClusterTestExtensionsTest.java 6KB

MockController.java 20KB

RemoteLogManagerTest.java 31KB

TestKitNodes.java 8KB

KafkaClusterTestKit.java 25KB

ReplicaFetcherTierStateMachine.java 15KB

ReplicaManagerBuilder.java 8KB

KafkaApisBuilder.java 7KB

LogManagerBuilder.java 7KB

RemoteLogManager.java 35KB

package.html 2KB

package.html 830B

package.html 1KB

SnapshotsTest.java 5KB

FileRawSnapshotTest.java 14KB

SnapshotWriterReaderTest.java 11KB

LeaderStateTest.java 25KB

MockLogTest.java 38KB

KafkaRaftClientTest.java 120KB

KafkaRaftClientSnapshotTest.java 73KB

CandidateStateTest.java 8KB

RaftClientTestContext.java 47KB

BatchBuilderTest.java 5KB

BatchAccumulatorTest.java 19KB

RecordsIteratorTest.java 13KB

BatchMemoryPoolTest.java 5KB

ThresholdPurgatoryTest.java 6KB

KafkaRaftMetricsTest.java 14KB

RecordsBatchReaderTest.java 4KB

RaftEventSimulationTest.java 47KB

ResignedStateTest.java 4KB

MockLog.java 24KB

RequestManagerTest.java 5KB

QuorumStateTest.java 44KB

RecordsSnapshotWriter.java 7KB

Snapshots.java 6KB

FileRawSnapshotWriter.java 6KB

RecordsSnapshotReader.java 5KB

KafkaRaftClient.java 107KB

RaftUtil.java 8KB

ResignedState.java 5KB

FollowerState.java 7KB

LeaderState.java 19KB

ReplicatedLog.java 12KB

RaftClient.java 12KB

ReplicatedCounter.java 7KB

RequestManager.java 7KB

BatchBuilder.java 12KB

KafkaRaftMetrics.java 10KB

BatchAccumulator.java 19KB

BatchMemoryPool.java 5KB

RecordsIterator.java 14KB

FuturePurgatory.java 4KB

QuorumState.java 21KB

CandidateState.java 9KB

ElectionState.java 4KB

Batch.java 6KB

FileBasedStateStore.java 7KB

RaftConfig.java 11KB

README.md 2KB

README.md 6KB

IsNullConditionalTest.java 4KB

VersionsTest.java 5KB

StructRegistryTest.java 7KB

VersionConditionalTest.java 9KB

MessageDataGeneratorTest.java 14KB

MetadataRecordTypeGenerator.java 7KB

Versions.java 7KB

MessageDataGenerator.java 88KB

IsNullConditional.java 4KB

MessageGenerator.java 15KB

StructRegistry.java 7KB

FieldType.java 13KB

FieldSpec.java 27KB

SchemaGenerator.java 16KB

MessageSpec.java 5KB

JsonConverterGenerator.java 24KB

MetadataJsonConvertersGenerator.java 5KB

VersionConditional.java 9KB

ApiMessageTypeGenerator.java 17KB

KafkaEventQueueTest.java 18KB

SnapshottableHashTableTest.java 13KB

TimelineHashSetTest.java 5KB

TimelineHashMapTest.java 5KB

BaseHashTableTest.java 6KB

BoundedListTest.java 7KB

MetadataVersionTest.java 16KB

CommandLineUtilsTest.java 10KB

FutureUtilsTest.java 6KB

MockScheduler.java 6KB

TranslatedValueMapViewTest.java 4KB

KafkaEventQueue.java 17KB

EventQueue.java 9KB

BaseHashTable.java 9KB

TimelineHashMap.java 11KB

SnapshotRegistry.java 8KB

SnapshottableHashTable.java 19KB

TimelineHashSet.java 7KB

BoundedList.java 6KB

KafkaYammerMetrics.java 6KB

KafkaMetricsGroup.java 6KB

AbstractApiMessageSerde.java 5KB

CheckpointFile.java 8KB

MetadataVersion.java 18KB

FutureUtils.java 4KB

CommandLineUtils.java 7KB

KafkaScheduler.java 6KB

ShutdownableThread.java 5KB

ServerTopicConfigSynonyms.java 7KB

README.md 13KB

Kafka 3.5.0 源代码包

文件列表

用户评论

推荐下载