kafka
Apache Kafka - 분산 이벤트 스트리밍 플랫폼
파일 탐색기
최종 버전 다운로드 (.zip)파일 수가 많아 일부만 표시됩니다. 전체 파일은 위 다운로드 버튼으로 확인해 주세요.
- action.yml
- action.yml
- action.yml
- action.yml
- action.yml
- labeler.yml
- checkstyle.py
- develocity_reports.py
- format-test-catalog.py
- junit.py
- label_small.sh
- pr-format.py
- pr-reviewers-trailer.py
- rat.py
- requirements.txt
- thread-dump.sh
- build.yml
- ci-complete.yml
- ci.yml
- deflake.yml
- docker_build_and_test.yml
- docker_official_image_build_and_test.yml
- docker_promote.yml
- docker_rc_release.yml
- docker_scan.yml
- generate-reports.yml
- pr-labeled.yml
- pr-labels-cron.yml
- pr-linter.yml
- pr-reviewed.yml
- pr-reviewers-trailer-on-comment.yml
- pr-reviewers-trailer-on-review.yml
- pr-update.yml
- prepare_docker_official_image_source.yml
- README.md
- stale.yml
- workflow-requested.yml
- dependabot.yml
- pull_request_template.md
- ApiSurface.java
- ApiSurfaceScanner.java
- CascadeValidator.java
- CheckResult.java
- ClassFacts.java
- JavadocConsistencyValidator.java
- PluginDeveloperApiUsageScanner.java
- PublicApiChecker.java
- PublicApiViolation.java
- ReasonCaptureVisitor.java
- ViolationReporter.java
- ApiSurfaceScannerTest.java
- ApiSurfaceTest.java
- CascadeValidatorTest.java
- JavadocConsistencyValidatorTest.java
- PluginDeveloperApiUsageScannerTest.java
- PublicApiCheckerTest.java
- AsmClassFactory.java
- TempJarBuilder.java
- build.gradle
- KafkaInternalApiCheckerExtension.java
- KafkaInternalApiCheckerPlugin.java
- KafkaInternalApiCheckerTask.java
- KafkaPublicApiCheckerExtension.java
- KafkaPublicApiCheckerPlugin.java
- KafkaPublicApiCheckerTask.java
- KafkaInternalApiCheckerPluginTest.java
- KafkaInternalApiCheckerTaskTest.java
- KafkaPublicApiCheckerTaskTest.java
- build.gradle
- KafkaInternalApiCheckerMojo.java
- plugin.xml
- PluginXmlParityTest.java
- build.gradle
- build.gradle
- README.md
- settings.gradle
- connect-distributed.bat
- connect-internal-topics.bat
- connect-plugin-path.bat
- connect-standalone.bat
- kafka-acls.bat
- kafka-broker-api-versions.bat
- kafka-client-metrics.bat
- kafka-cluster.bat
- kafka-configs.bat
- kafka-console-consumer.bat
- kafka-console-producer.bat
- kafka-console-share-consumer.bat
- kafka-consumer-groups.bat
- kafka-consumer-perf-test.bat
- kafka-delegation-tokens.bat
- kafka-delete-records.bat
- kafka-dump-log.bat
- kafka-e2e-latency.bat
- kafka-features.bat
- kafka-get-offsets.bat
- kafka-groups.bat
- kafka-jmx.bat
- kafka-leader-election.bat
- kafka-log-dirs.bat
- kafka-metadata-quorum.bat
- kafka-producer-perf-test.bat
- kafka-reassign-partitions.bat
- kafka-replica-verification.bat
- kafka-run-class.bat
- kafka-server-start.bat
- kafka-server-stop.bat
- kafka-share-consumer-perf-test.bat
- kafka-share-groups.bat
- kafka-storage.bat
- kafka-streams-application-reset.bat
- kafka-topics.bat
- kafka-transactions.bat
- connect-distributed.sh
- connect-internal-topics.sh
- connect-mirror-maker.sh
- connect-plugin-path.sh
- connect-standalone.sh
- kafka-acls.sh
- kafka-broker-api-versions.sh
- kafka-client-metrics.sh
- kafka-cluster.sh
- kafka-configs.sh
- kafka-console-consumer.sh
- kafka-console-producer.sh
- kafka-console-share-consumer.sh
- kafka-consumer-groups.sh
- kafka-consumer-perf-test.sh
- kafka-delegation-tokens.sh
- kafka-delete-records.sh
- kafka-dump-log.sh
- kafka-e2e-latency.sh
- kafka-features.sh
- kafka-get-offsets.sh
- kafka-groups.sh
- kafka-jmx.sh
- kafka-leader-election.sh
- kafka-log-dirs.sh
- kafka-metadata-quorum.sh
- kafka-metadata-shell.sh
- kafka-producer-perf-test.sh
- kafka-reassign-partitions.sh
- kafka-replica-verification.sh
- kafka-run-class.sh
- kafka-server-start.sh
- kafka-server-stop.sh
- kafka-share-consumer-perf-test.sh
- kafka-share-groups.sh
- kafka-storage.sh
- kafka-streams-application-reset.sh
- kafka-streams-groups.sh
- kafka-topics.sh
- kafka-transactions.sh
- kafka-verifiable-consumer.sh
- kafka-verifiable-producer.sh
- kafka-verifiable-share-consumer.sh
- trogdor.sh
- .scalafmt.conf
- checkstyle.xml
- import-control-api-checker-test.xml
- import-control-api-checker.xml
- import-control-clients-integration-tests.xml
- import-control-coordinator-common.xml
- import-control-core.xml
- import-control-examples.xml
- import-control-group-coordinator.xml
- import-control-jmh-benchmarks.xml
- import-control-metadata.xml
- import-control-server-common.xml
- import-control-server.xml
- import-control-share-coordinator.xml
- import-control-storage.xml
- import-control-test-common-internal-api.xml
- import-control-test-common-runtime.xml
- import-control-test-common-util.xml
- import-control-transaction-coordinator.xml
- import-control.xml
- java.header
- suppressions.xml
- AddPartitionsTest.java
- AdminClientTimeoutIntegrationTest.java
- AdminClientWithPoliciesIntegrationTest.java
- AdminFenceProducersTest.java
- AdminMetadataTest.java
- AutoTopicCreationTest.java
- ClientTelemetryTest.java
- ConcurrentListOffsetsRequestTest.java
- DeleteTopicTest.java
- DescribeAuthorizedOperationsTest.java
- DescribeFeaturesTest.java
- DescribeProducersWithBrokerIdTest.java
- DynamicGroupConfigIntegrationTest.java
- ListOffsetsIntegrationTest.java
- RackAwareAutoTopicCreationTest.java
- StaticBrokerConfigTest.java
- ConsumerAssignmentPoller.java
- ConsumerBounceTest.java
- ConsumerIntegrationTest.java
- ConsumerTopicCreationTest.java
- ConsumerWithLegacyMessageFormatIntegrationTest.java
- PlaintextConsumerAssignTest.java
- PlaintextConsumerCallbackTest.java
- PlaintextConsumerCloseTest.java
- PlaintextConsumerCommitTest.java
- PlaintextConsumerFetchTest.java
- PlaintextConsumerPollTest.java
- PlaintextConsumerSubscriptionTest.java
- PlaintextConsumerTest.java
- RackAwareTestAssignor.java
- SaslPlainPlaintextConsumerTest.java
- SaslPlaintextConsumerTest.java
- ShareConsumerCallbackTest.java
- ShareConsumerDeliveryTest.java
- ShareConsumerDLQTest.java
- ShareConsumerLagTest.java
- ShareConsumerRackAwareTest.java
- ShareConsumerRenewTest.java
- ShareConsumerTest.java
- ShareConsumerTestBase.java
- ProducerCompressionTest.java
- ProducerFailureHandlingTest.java
- ProducerIdExpirationTest.java
- ProducerIntegrationTest.java
- ProducerSendWhileDeletionTest.java
- GroupAuthorizerIntegrationTest.java
- ClientRebootstrapTest.java
- ClientsTestUtils.java
- CreateTopicsRequestTest.java
- CreateTopicsRequestWithPolicyTest.java
- MetadataVersionIntegrationTest.java
- MetricsDuringTopicCreationDeletionTest.java
- SocketServerMemoryPoolTest.java
- CustomQuotaCallbackTest.java
- log4j2.yaml
- AbortTransactionHandler.java
- AdminApiDriver.java
- AdminApiFuture.java
- AdminApiHandler.java
- AdminApiLookupStrategy.java
- AdminFetchMetricsManager.java
- AdminMetadataManager.java
- AdminUtils.java
- AllBrokersStrategy.java
- AlterConsumerGroupOffsetsHandler.java
- AlterShareGroupOffsetsHandler.java
- ApiRequestScope.java
- CoordinatorKey.java
- CoordinatorStrategy.java
- DeleteConsumerGroupOffsetsHandler.java
- DeleteConsumerGroupsHandler.java
- DeleteGroupsHandler.java
- DeleteRecordsHandler.java
- DeleteShareGroupOffsetsHandler.java
- DeleteShareGroupsHandler.java
- DescribeClassicGroupsHandler.java
- DescribeConsumerGroupsHandler.java
- DescribeProducersHandler.java
- DescribeShareGroupsHandler.java
- DescribeStreamsGroupsHandler.java
- DescribeTransactionsHandler.java
- FenceProducersHandler.java
- InternalDescribeFeaturesResult.java
- ListConsumerGroupOffsetsHandler.java
- ListOffsetsHandler.java
- ListShareGroupOffsetsHandler.java
- ListTransactionsHandler.java
- PartitionLeaderCache.java
- PartitionLeaderStrategy.java
- RemoveMembersFromConsumerGroupHandler.java
- StaticBrokerStrategy.java
- AbortTransactionOptions.java
- AbortTransactionResult.java
- AbortTransactionSpec.java
- AbstractOptions.java
- AddRaftVoterOptions.java
- AddRaftVoterResult.java
- Admin.java
- AdminClient.java
- AdminClientConfig.java
- AlterClientQuotasOptions.java
- AlterClientQuotasResult.java
- AlterConfigOp.java
- AlterConfigsOptions.java
- AlterConfigsResult.java
- AlterConsumerGroupOffsetsOptions.java
- AlterConsumerGroupOffsetsResult.java
- AlterPartitionReassignmentsOptions.java
- AlterPartitionReassignmentsResult.java
- AlterReplicaLogDirsOptions.java
- AlterReplicaLogDirsResult.java
- AlterShareGroupOffsetsOptions.java
- AlterShareGroupOffsetsResult.java
- AlterStreamsGroupOffsetsOptions.java
- AlterStreamsGroupOffsetsResult.java
- AlterUserScramCredentialsOptions.java
- AlterUserScramCredentialsResult.java
- ClassicGroupDescription.java
- ClientMetricsResourceListing.java
- Config.java
- ConfigEntry.java
- ConsumerGroupDescription.java
- ConsumerGroupListing.java
- CreateAclsOptions.java
- CreateAclsResult.java
- CreateDelegationTokenOptions.java
- CreateDelegationTokenResult.java
- CreatePartitionsOptions.java
- CreatePartitionsResult.java
- CreateTopicsOptions.java
- CreateTopicsResult.java
- DeleteAclsOptions.java
- DeleteAclsResult.java
- DeleteConsumerGroupOffsetsOptions.java
- DeleteConsumerGroupOffsetsResult.java
- DeleteConsumerGroupsOptions.java
- DeleteConsumerGroupsResult.java
- DeletedRecords.java
- DeleteRecordsOptions.java
- DeleteRecordsResult.java
- DeleteShareGroupOffsetsOptions.java
- DeleteShareGroupOffsetsResult.java
- DeleteShareGroupsOptions.java
- DeleteShareGroupsResult.java
- DeleteStreamsGroupOffsetsOptions.java
- DeleteStreamsGroupOffsetsResult.java
- DeleteStreamsGroupsOptions.java
- DeleteStreamsGroupsResult.java
- DeleteTopicsOptions.java
- DeleteTopicsResult.java
- DescribeAclsOptions.java
- DescribeAclsResult.java
- DescribeClassicGroupsOptions.java
- DescribeClassicGroupsResult.java
- DescribeClientQuotasOptions.java
- DescribeClientQuotasResult.java
- DescribeClusterOptions.java
- DescribeClusterResult.java
- DescribeConfigsOptions.java
- DescribeConfigsResult.java
- DescribeConsumerGroupsOptions.java
- DescribeConsumerGroupsResult.java
- DescribeDelegationTokenOptions.java
- DescribeDelegationTokenResult.java
- DescribeFeaturesOptions.java
- DescribeFeaturesResult.java
- DescribeLogDirsOptions.java
- DescribeLogDirsResult.java
- DescribeMetadataQuorumOptions.java
- DescribeMetadataQuorumResult.java
- DescribeProducersOptions.java
- DescribeProducersResult.java
- DescribeReplicaLogDirsOptions.java
- DescribeReplicaLogDirsResult.java
- DescribeShareGroupsOptions.java
- DescribeShareGroupsResult.java
- DescribeStreamsGroupsOptions.java
- DescribeStreamsGroupsResult.java
- DescribeTopicsOptions.java
- DescribeTopicsResult.java
- DescribeTransactionsOptions.java
- DescribeTransactionsResult.java
- DescribeUserScramCredentialsOptions.java
- DescribeUserScramCredentialsResult.java
- ElectLeadersOptions.java
- ElectLeadersResult.java
- EndpointType.java
- ExpireDelegationTokenOptions.java
- ExpireDelegationTokenResult.java
- FeatureMetadata.java
- FeatureUpdate.java
- FenceProducersOptions.java
- FenceProducersResult.java
- FinalizedVersionRange.java
- ForwardingAdmin.java
- GroupListing.java
- KafkaAdminClient.java
- ListClientMetricsResourcesOptions.java
- ListClientMetricsResourcesResult.java
- ListConfigResourcesOptions.java
- ListConfigResourcesResult.java
- ListConsumerGroupOffsetsOptions.java
- ListConsumerGroupOffsetsResult.java
- ListConsumerGroupOffsetsSpec.java
- ListConsumerGroupsOptions.java
- ListConsumerGroupsResult.java
- ListGroupsOptions.java
- ListGroupsResult.java
- ListOffsetsOptions.java
- ListOffsetsResult.java
- ListPartitionReassignmentsOptions.java
- ListPartitionReassignmentsResult.java
- ListShareGroupOffsetsOptions.java
- ListShareGroupOffsetsResult.java
- ListShareGroupOffsetsSpec.java
- ListStreamsGroupOffsetsOptions.java
- ListStreamsGroupOffsetsResult.java
- ListStreamsGroupOffsetsSpec.java
- ListTopicsOptions.java
- ListTopicsResult.java
- ListTransactionsOptions.java
- ListTransactionsResult.java
- LogDirDescription.java
- MemberAssignment.java
- MemberDescription.java
- MemberToRemove.java
- NewPartitionReassignment.java
- NewPartitions.java
- NewTopic.java
- OffsetSpec.java
- package-info.java
- PartitionReassignment.java
- ProducerState.java
- QuorumInfo.java
- RaftVoterEndpoint.java
- RecordsToDelete.java
- RemoveMembersFromConsumerGroupOptions.java
- RemoveMembersFromConsumerGroupResult.java
- RemoveRaftVoterOptions.java
- RemoveRaftVoterResult.java
- RenewDelegationTokenOptions.java
- RenewDelegationTokenResult.java
- ReplicaInfo.java
- ScramCredentialInfo.java
- ScramMechanism.java
- ShareGroupDescription.java
- ShareMemberAssignment.java
- ShareMemberDescription.java
- SharePartitionOffsetInfo.java
- StreamsGroupDescription.java
- StreamsGroupMemberAssignment.java
- StreamsGroupMemberDescription.java
- StreamsGroupSubtopologyDescription.java
- StreamsGroupTopologyDescription.java
- StreamsGroupTopologyDescriptionStatus.java
- SupportedVersionRange.java
- TerminateTransactionOptions.java
- TerminateTransactionResult.java
- TopicDescription.java
- TopicListing.java
- TransactionDescription.java
- TransactionListing.java
- TransactionState.java
- UnregisterBrokerOptions.java
- UnregisterBrokerResult.java
- UnregisterControllerOptions.java
- UnregisterControllerResult.java
- UpdateFeaturesOptions.java
- UpdateFeaturesResult.java
- UserScramCredentialAlteration.java
- UserScramCredentialDeletion.java
- UserScramCredentialsDescription.java
- UserScramCredentialUpsertion.java
- AbstractTopicMetadataEvent.java
- AllTopicsMetadataEvent.java
- ApplicationEvent.java
- ApplicationEventHandler.java
- ApplicationEventProcessor.java
- ApplyAssignmentEvent.java
- AssignmentChangeEvent.java
- AsyncCommitEvent.java
- AsyncPollEvent.java
- BackgroundEvent.java
- BackgroundEventHandler.java
- CheckAndUpdatePositionsEvent.java
- CommitEvent.java
- CommitOnCloseEvent.java
- CompletableApplicationEvent.java
- CompletableBackgroundEvent.java
- CompletableEvent.java
- CompletableEventReaper.java
- ConsumerRebalanceListenerCallbackCompletedEvent.java
- CreateFetchRequestsEvent.java
- CurrentLagEvent.java
- ErrorEvent.java
- EventProcessor.java
- FetchCommittedOffsetsEvent.java
- LeaveGroupOnCloseEvent.java
- ListOffsetsEvent.java
- MetadataErrorNotifiableEvent.java
- PartitionsAssignedEvent.java
- PartitionsRemovedEvent.java
- PausePartitionsEvent.java
- ResetOffsetEvent.java
- ResumePartitionsEvent.java
- SeekUnvalidatedEvent.java
- ShareAcknowledgeAsyncEvent.java
- ShareAcknowledgementCommitCallbackRegistrationEvent.java
- ShareAcknowledgementEvent.java
- ShareAcknowledgementEventHandler.java
- ShareAcknowledgeOnCloseEvent.java
- ShareAcknowledgeSyncEvent.java
- ShareFetchEvent.java
- SharePollEvent.java
- ShareSubscriptionChangeEvent.java
- ShareUnsubscribeEvent.java
- StopFindCoordinatorOnCloseEvent.java
- StreamsOnAllTasksLostCallbackCompletedEvent.java
- StreamsOnAllTasksLostCallbackNeededEvent.java
- StreamsOnTasksAssignedCallbackCompletedEvent.java
- StreamsOnTasksRevokedCallbackCompletedEvent.java
- StreamsOnTasksRevokedCallbackNeededEvent.java
- StreamsTasksAssignedEvent.java
- SubscriptionChangeEvent.java
- SyncCommitEvent.java
- TopicMetadataEvent.java
- TopicPatternSubscriptionChangeEvent.java
- TopicRe2JPatternSubscriptionChangeEvent.java
- TopicSubscriptionChangeEvent.java
- UnsubscribeEvent.java
- UpdatePatternSubscriptionEvent.java
- AbstractConsumerMetricsManager.java
- AsyncConsumerMetrics.java
- ConsumerRebalanceMetricsManager.java
- HeartbeatMetricsManager.java
- KafkaConsumerMetrics.java
- KafkaShareConsumerMetrics.java
- MetricsLedger.java
- OffsetCommitMetricsManager.java
- RebalanceCallbackMetricsManager.java
- RebalanceMetricsManager.java
- SensorBuilder.java
- ShareRebalanceMetricsManager.java
- AbstractCoordinator.java
- AbstractFetch.java
- AbstractHeartbeatRequestManager.java
- AbstractMembershipManager.java
- AbstractPartitionAssignor.java
- AbstractStickyAssignor.java
- AcknowledgementBatch.java
- AcknowledgementCommitCallbackHandler.java
- Acknowledgements.java
- AsyncClient.java
- AsyncKafkaConsumer.java
- AutoOffsetResetStrategy.java
- BaseHeartbeatThread.java
- CachedSupplier.java
- ClassicKafkaConsumer.java
- CommitRequestManager.java
- CompletedFetch.java
- ConsumerCoordinator.java
- ConsumerDelegate.java
- ConsumerDelegateCreator.java
- ConsumerHeartbeatRequestManager.java
- ConsumerInterceptors.java
- ConsumerMembershipManager.java
- ConsumerMetadata.java
- ConsumerNetworkClient.java
- ConsumerNetworkThread.java
- ConsumerProtocol.java
- ConsumerRebalanceListenerInvoker.java
- ConsumerRebalanceListenerMethodName.java
- ConsumerUtils.java
- CoordinatorRequestManager.java
- DelegatingRebalanceConsumer.java
- Deserializers.java
- Fetch.java
- FetchBuffer.java
- FetchCollector.java
- FetchConfig.java
- Fetcher.java
- FetchMetricsAggregator.java
- FetchMetricsManager.java
- FetchMetricsRegistry.java
- FetchRequestManager.java
- FetchUtils.java
- GroupCoordinatorNode.java
- Heartbeat.java
- HeartbeatRequestState.java
- MemberState.java
- MemberStateListener.java
- NetworkClientDelegate.java
- NoAvailableBrokersException.java
- NodeAcknowledgements.java
- OffsetAndTimestampInternal.java
- OffsetCommitCallbackInvoker.java
- OffsetFetcher.java
- OffsetFetcherUtils.java
- OffsetsForLeaderEpochClient.java
- OffsetsForLeaderEpochUtils.java
- OffsetsRequestManager.java
- PositionsValidator.java
- RequestFuture.java
- RequestFutureAdapter.java
- RequestFutureListener.java
- RequestManager.java
- RequestManagers.java
- RequestState.java
- ShareAcknowledgementMode.java
- ShareAcquireMode.java
- ShareCompletedFetch.java
- ShareConsumerDelegate.java
- ShareConsumerDelegateCreator.java
- ShareConsumeRequestManager.java
- ShareConsumerImpl.java
- ShareConsumerMetadata.java
- ShareConsumerMetrics.java
- ShareFetch.java
- ShareFetchBuffer.java
- ShareFetchCollector.java
- ShareFetchConfig.java
- ShareFetchException.java
- ShareFetchMetricsAggregator.java
- ShareFetchMetricsManager.java
- ShareFetchMetricsRegistry.java
- ShareHeartbeatRequestManager.java
- ShareInFlightBatch.java
- ShareInFlightBatchException.java
- ShareMembershipManager.java
- ShareSessionHandler.java
- StreamsGroupHeartbeatRequestManager.java
- StreamsGroupTopologyDescriptionRequestManager.java
- StreamsMembershipManager.java
- StreamsRebalanceData.java
- StreamsRebalanceListener.java
- StreamsRebalanceListenerInvoker.java
- SubscriptionState.java
- TimedRequestState.java
- TopicIdPartitionSet.java
- TopicMetadataFetcher.java
- TopicMetadataRequestManager.java
- Utils.java
- WakeupTrigger.java
- AcknowledgementCommitCallback.java
- AcknowledgeType.java
- CloseOptions.java
- CommitFailedException.java
- Consumer.java
- ConsumerConfig.java
- ConsumerGroupMetadata.java
- ConsumerInterceptor.java
- ConsumerPartitionAssignor.java
- ConsumerRebalanceListener.java
- ConsumerRecord.java
- ConsumerRecords.java
- CooperativeStickyAssignor.java
- GroupProtocol.java
- InvalidOffsetException.java
- KafkaConsumer.java
- KafkaShareConsumer.java
- LogTruncationException.java
- MockConsumer.java
- MockShareConsumer.java
- NoOffsetForPartitionException.java
- OffsetAndMetadata.java
- OffsetAndTimestamp.java
- OffsetCommitCallback.java
- OffsetOutOfRangeException.java
- OffsetResetStrategy.java
- package-info.java
- RangeAssignor.java
- RebalanceConsumer.java
- RebalanceListener.java
- RetriableCommitFailedException.java
- RoundRobinAssignor.java
- ShareConsumer.java
- ShareConsumerConfig.java
- StickyAssignor.java
- SubscriptionPattern.java
- BufferPool.java
- BuiltInPartitioner.java
- ChunkedByteBufferOutputStream.java
- ChunkedProducerBatch.java
- ChunkedRecordAccumulator.java
- ErrorLoggingCallback.java
- FutureRecordMetadata.java
- IncompleteBatches.java
- KafkaProducerMetrics.java
- ProducerBatch.java
- ProduceRequestResult.java
- ProducerInterceptors.java
- ProducerMetadata.java
- ProducerMetrics.java
- RecordAccumulator.java
- Sender.java
- SenderMetricsRegistry.java
- TransactionalRequestResult.java
- TransactionManager.java
- TxnPartitionEntry.java
- TxnPartitionMap.java
- BufferExhaustedException.java
- Callback.java
- KafkaProducer.java
- MockProducer.java
- package-info.java
- Partitioner.java
- PreparedTxnState.java
- Producer.java
- ProducerConfig.java
- ProducerInterceptor.java
- ProducerRecord.java
- RecordMetadata.java
- RoundRobinPartitioner.java
- ApiVersions.java
- BootstrapConfiguration.java
- ClientDnsLookup.java
- ClientRequest.java
- ClientResponse.java
- ClientUtils.java
- ClusterConnectionStates.java
- CommonClientConfigs.java
- ConnectionState.java
- DefaultHostResolver.java
- FetchSessionHandler.java
- GroupRebalanceConfig.java
- HostResolver.java
- InFlightRequests.java
- KafkaClient.java
- LeastLoadedNode.java
- ManualMetadataUpdater.java
- Metadata.java
- MetadataRecoveryStrategy.java
- MetadataSnapshot.java
- MetadataUpdater.java
- NetworkClient.java
- NetworkClientUtils.java
- NodeApiVersions.java
- RequestCompletionHandler.java
- StaleMetadataException.java
- AccessControlEntry.java
- AccessControlEntryData.java
- AccessControlEntryFilter.java
- AclBinding.java
- AclBindingFilter.java
- AclOperation.java
- AclPermissionType.java
- package-info.java
- InterfaceAudience.java
- InterfaceStability.java
- package-info.java
- SuppressKafkaInternalApiUsage.java
- Cache.java
- LRUCache.java
- package-info.java
- SynchronizedCache.java
- Compression.java
- GzipCompression.java
- GzipOutputStream.java
- Lz4BlockInputStream.java
- Lz4BlockOutputStream.java
- Lz4Compression.java
- NoCompression.java
- package-info.java
- SnappyCompression.java
- ZstdCompression.java
- AllowedPaths.java
- BrokerSecurityConfigs.java
- ConfigProvider.java
- DirectoryConfigProvider.java
- EnvVarConfigProvider.java
- FileConfigProvider.java
- package-info.java
- package-info.java
- Password.java
- AbstractConfig.java
- Config.java
- ConfigChangeCallback.java
- ConfigData.java
- ConfigDef.java
- ConfigException.java
- ConfigResource.java
- ConfigTransformer.java
- ConfigTransformerResult.java
- ConfigValue.java
- LogLevelConfig.java
- package-info.java
- SaslConfigs.java
- SecurityConfig.java
- SslClientAuth.java
- SslConfigs.java
- TopicConfig.java
- ApiException.java
- ApplicationRecoverableException.java
- AuthenticationException.java
- AuthorizationException.java
- AuthorizerNotReadyException.java
- BootstrapResolutionException.java
- BrokerIdNotRegisteredException.java
- BrokerNotAvailableException.java
- ClusterAuthorizationException.java
- ConcurrentTransactionsException.java
- ControllerIdNotRegisteredException.java
- ControllerMovedException.java
- CoordinatorLoadInProgressException.java
- CoordinatorNotAvailableException.java
- CorruptRecordException.java
- DelegationTokenAuthorizationException.java
- DelegationTokenDisabledException.java
- DelegationTokenExpiredException.java
- DelegationTokenNotFoundException.java
- DelegationTokenOwnerMismatchException.java
- DisconnectException.java
- DuplicateBrokerRegistrationException.java
- DuplicateResourceException.java
- DuplicateSequenceException.java
- DuplicateVoterException.java
- ElectionNotNeededException.java
- EligibleLeadersNotAvailableException.java
- FeatureUpdateFailedException.java
- FencedInstanceIdException.java
- FencedLeaderEpochException.java
- FencedMemberEpochException.java
- FencedStateEpochException.java
- FetchSessionIdNotFoundException.java
- FetchSessionTopicIdException.java
- GroupAuthorizationException.java
- GroupDeletionFailedException.java
- GroupIdNotFoundException.java
- GroupMaxSizeReachedException.java
- GroupNotEmptyException.java
- GroupSubscribedToTopicException.java
- IllegalGenerationException.java
- IllegalSaslStateException.java
- InconsistentClusterIdException.java
- InconsistentGroupProtocolException.java
- InconsistentTopicIdException.java
- InconsistentVoterSetException.java
- IneligibleReplicaException.java
- InterruptException.java
- InvalidCommitOffsetSizeException.java
- InvalidConfigurationException.java
- InvalidFetchSessionEpochException.java
- InvalidFetchSizeException.java
- InvalidGroupIdException.java
- InvalidMetadataException.java
- InvalidOffsetException.java
- InvalidPartitionsException.java
- InvalidPidMappingException.java
- InvalidPrincipalTypeException.java
- InvalidProducerEpochException.java
- InvalidRecordStateException.java
- InvalidRegistrationException.java
- InvalidRegularExpression.java
- InvalidReplicaAssignmentException.java
- InvalidReplicationFactorException.java
- InvalidRequestException.java
- InvalidRequiredAcksException.java
- InvalidSessionTimeoutException.java
- InvalidShareSessionEpochException.java
- InvalidTimestampException.java
- InvalidTopicException.java
- InvalidTxnStateException.java
- InvalidTxnTimeoutException.java
- InvalidUpdateVersionException.java
- InvalidVoterKeyException.java
- KafkaStorageException.java
- LeaderNotAvailableException.java
- ListenerNotFoundException.java
- LogDirNotFoundException.java
- MemberIdRequiredException.java
- MismatchedEndpointTypeException.java
- NetworkException.java
- NewLeaderElectedException.java
- NoReassignmentInProgressException.java
- NotControllerException.java
- NotCoordinatorException.java
- NotEnoughReplicasAfterAppendException.java
- NotEnoughReplicasException.java
- NotLeaderOrFollowerException.java
- OffsetMetadataTooLarge.java
- OffsetMovedToTieredStorageException.java
- OffsetNotAvailableException.java
- OffsetOutOfRangeException.java
- OperationNotAttemptedException.java
- OutOfOrderSequenceException.java
- package-info.java
- PolicyViolationException.java
- PositionOutOfRangeException.java
- PreferredLeaderNotAvailableException.java
- PrincipalDeserializationException.java
- ProducerFencedException.java
- ReassignmentInProgressException.java
- RebalanceInProgressException.java
- RebootstrapRequiredException.java
- RecordBatchTooLargeException.java
- RecordDeserializationException.java
- RecordTooLargeException.java
- RefreshRetriableException.java
- ReplicaNotAvailableException.java
- ResourceNotFoundException.java
- RetriableException.java
- SaslAuthenticationException.java
- SecurityDisabledException.java
- SerializationException.java
- ShareSessionLimitReachedException.java
- ShareSessionNotFoundException.java
- SnapshotNotFoundException.java
- SslAuthenticationException.java
- StaleBrokerEpochException.java
- StaleMemberEpochException.java
- StreamsInvalidTopologyEpochException.java
- StreamsInvalidTopologyException.java
- StreamsTopologyDescriptionUpdateFailedException.java
- StreamsTopologyFencedException.java
- TelemetryTooLargeException.java
- ThrottlingQuotaExceededException.java
- TimeoutException.java
- TopicAuthorizationException.java
- TopicDeletionDisabledException.java
- TopicExistsException.java
- TransactionAbortableException.java
- TransactionAbortedException.java
- TransactionalIdAuthorizationException.java
- TransactionalIdNotFoundException.java
- TransactionCoordinatorFencedException.java
- UnacceptableCredentialException.java
- UnknownControllerIdException.java
- UnknownLeaderEpochException.java
- UnknownMemberIdException.java
- UnknownProducerIdException.java
- UnknownServerException.java
- UnknownSubscriptionIdException.java
- UnknownTopicIdException.java
- UnknownTopicOrPartitionException.java
- UnreleasedInstanceIdException.java
- UnstableOffsetCommitException.java
- UnsupportedAssignorException.java
- UnsupportedByAuthenticationException.java
- UnsupportedCompressionTypeException.java
- UnsupportedEndpointTypeException.java
- UnsupportedForMessageFormatException.java
- UnsupportedSaslMechanismException.java
- UnsupportedVersionException.java
- VoterNotFoundException.java
- WakeupException.java
- BaseVersionRange.java
- Features.java
- package-info.java
- SupportedVersionRange.java
- RecordHeader.java
- RecordHeaders.java
- Header.java
- Headers.java
- package-info.java
- ClusterResourceListeners.java
- CompositeStrategy.java
- FatalExitError.java
- IdempotentCloser.java
- KafkaCompletableFuture.java
- KafkaFutureImpl.java
- LegacyStrategy.java
- ModernStrategy.java
- PartitionStates.java
- Plugin.java
- ReflectiveStrategy.java
- SecurityManagerCompatibility.java
- Topic.java
- UnsupportedProtocolFieldException.java
- UnsupportedStrategy.java
- GarbageCollectedMemoryPool.java
- MemoryPool.java
- package-info.java
- SimpleMemoryPool.java
- IntGaugeSuite.java
- MetricsUtils.java
- PluginMetricsImpl.java
- Avg.java
- CumulativeCount.java
- CumulativeSum.java
- Frequencies.java
- Frequency.java
- Histogram.java
- Max.java
- Meter.java
- Min.java
- package-info.java
- Percentile.java
- Percentiles.java
- Rate.java
- SampledStat.java
- SimpleRate.java
- TokenBucket.java
- Value.java
- WindowedCount.java
- WindowedSum.java
- CompoundStat.java
- Gauge.java
- JmxReporter.java
- KafkaMetric.java
- KafkaMetricsContext.java
- Measurable.java
- MeasurableStat.java
- MetricConfig.java
- Metrics.java
- MetricsContext.java
- MetricsReporter.java
- MetricValueProvider.java
- Monitorable.java
- package-info.java
- PluginMetrics.java
- Quota.java
- QuotaViolationException.java
- Sensor.java
- Stat.java
- Authenticator.java
- ByteBufferSend.java
- ChannelBuilder.java
- ChannelBuilders.java
- ChannelMetadataRegistry.java
- ChannelState.java
- CipherInformation.java
- ClientInformation.java
- ConnectionMode.java
- DelayedResponseAuthenticationException.java
- InvalidReceiveException.java
- KafkaChannel.java
- ListenerName.java
- ListenerReconfigurable.java
- NetworkReceive.java
- NetworkSend.java
- package-info.java
- PlaintextChannelBuilder.java
- PlaintextTransportLayer.java
- ReauthenticationContext.java
- Receive.java
- SaslChannelBuilder.java
- Selectable.java
- Selector.java
- Send.java
- ServerConnectionId.java
- SslChannelBuilder.java
- SslTransportLayer.java
- TransferableChannel.java
- TransportLayer.java
- ArrayOf.java
- BoundField.java
- CompactArrayOf.java
- Field.java
- NullableSchema.java
- package-info.java
- RawTaggedField.java
- RawTaggedFieldWriter.java
- Schema.java
- SchemaException.java
- Struct.java
- TaggedFields.java
- Type.java
- ApiKeys.java
- ApiMessage.java
- ByteBufferAccessor.java
- DataOutputStreamWritable.java
- Errors.java
- Message.java
- MessageSizeAccumulator.java
- MessageUtil.java
- ObjectSerializationCache.java
- package-info.java
- Protocol.java
- Readable.java
- SendBuilder.java
- Writable.java
- ClientQuotaAlteration.java
- ClientQuotaEntity.java
- ClientQuotaFilter.java
- ClientQuotaFilterComponent.java
- package-info.java
- AbstractLegacyRecordBatch.java
- AbstractRecordBatch.java
- AbstractRecords.java
- BaseRecords.java
- ByteBufferLogInputStream.java
- CompressionRatioEstimator.java
- CompressionType.java
- ControlRecordType.java
- ControlRecordUtils.java
- DefaultRecord.java
- DefaultRecordBatch.java
- DefaultRecordsSend.java
- EndTransactionMarker.java
- FileLogInputStream.java
- FileRecords.java
- LegacyRecord.java
- LogInputStream.java
- MemoryRecords.java
- MemoryRecordsBuilder.java
- MultiRecordsSend.java
- MutableRecordBatch.java
- package-info.java
- PartialDefaultRecord.java
- Record.java
- RecordBatch.java
- RecordBatchIterator.java
- Records.java
- RecordsSend.java
- RecordVersion.java
- RemoteLogInputStream.java
- SimpleRecord.java
- TransferableRecords.java
- UnalignedFileRecords.java
- UnalignedMemoryRecords.java
- UnalignedRecords.java
- package-info.java
- TimestampType.java
- ClientMetadata.java
- package-info.java
- PartitionView.java
- RackAwareReplicaSelector.java
- ReplicaSelector.java
- ReplicaView.java
- AbstractRequest.java
- AbstractRequestResponse.java
- AbstractResponse.java
- AddOffsetsToTxnRequest.java
- AddOffsetsToTxnResponse.java
- AddPartitionsToTxnRequest.java
- AddPartitionsToTxnResponse.java
- AddRaftVoterRequest.java
- AddRaftVoterResponse.java
- AllocateProducerIdsRequest.java
- AllocateProducerIdsResponse.java
- AlterClientQuotasRequest.java
- AlterClientQuotasResponse.java
- AlterConfigsRequest.java
- AlterConfigsResponse.java
- AlterPartitionReassignmentsRequest.java
- AlterPartitionReassignmentsResponse.java
- AlterPartitionRequest.java
- AlterPartitionResponse.java
- AlterReplicaLogDirsRequest.java
- AlterReplicaLogDirsResponse.java
- AlterShareGroupOffsetsRequest.java
- AlterShareGroupOffsetsResponse.java
- AlterUserScramCredentialsRequest.java
- AlterUserScramCredentialsResponse.java
- ApiError.java
- ApiVersionsRequest.java
- ApiVersionsResponse.java
- AssignReplicasToDirsRequest.java
- AssignReplicasToDirsResponse.java
- BeginQuorumEpochRequest.java
- BeginQuorumEpochResponse.java
- BrokerHeartbeatRequest.java
- BrokerHeartbeatResponse.java
- BrokerRegistrationRequest.java
- BrokerRegistrationResponse.java
- ConsumerGroupDescribeRequest.java
- ConsumerGroupDescribeResponse.java
- ConsumerGroupHeartbeatRequest.java
- ConsumerGroupHeartbeatResponse.java
- ControllerRegistrationRequest.java
- ControllerRegistrationResponse.java
- CorrelationIdMismatchException.java
- CreateAclsRequest.java
- CreateAclsResponse.java
- CreateDelegationTokenRequest.java
- CreateDelegationTokenResponse.java
- CreatePartitionsRequest.java
- CreatePartitionsResponse.java
- CreateTopicsRequest.java
- CreateTopicsResponse.java
- DeleteAclsRequest.java
- DeleteAclsResponse.java
- DeleteGroupsRequest.java
- DeleteGroupsResponse.java
- DeleteRecordsRequest.java
- DeleteRecordsResponse.java
- DeleteShareGroupOffsetsRequest.java
- DeleteShareGroupOffsetsResponse.java
- DeleteShareGroupStateRequest.java
- DeleteShareGroupStateResponse.java
- DeleteTopicsRequest.java
- DeleteTopicsResponse.java
- DescribeAclsRequest.java
- DescribeAclsResponse.java
- DescribeClientQuotasRequest.java
- DescribeClientQuotasResponse.java
- DescribeClusterRequest.java
- DescribeClusterResponse.java
- DescribeConfigsRequest.java
- DescribeConfigsResponse.java
- DescribeDelegationTokenRequest.java
- DescribeDelegationTokenResponse.java
- DescribeGroupsRequest.java
- DescribeGroupsResponse.java
- DescribeLogDirsRequest.java
- DescribeLogDirsResponse.java
- DescribeProducersRequest.java
- DescribeProducersResponse.java
- DescribeQuorumRequest.java
- DescribeQuorumResponse.java
- DescribeShareGroupOffsetsRequest.java
- DescribeShareGroupOffsetsResponse.java
- DescribeTopicPartitionsRequest.java
- DescribeTopicPartitionsResponse.java
- DescribeTransactionsRequest.java
- DescribeTransactionsResponse.java
- DescribeUserScramCredentialsRequest.java
- DescribeUserScramCredentialsResponse.java
- ElectLeadersRequest.java
- ElectLeadersResponse.java
- EndQuorumEpochRequest.java
- EndQuorumEpochResponse.java
- EndTxnRequest.java
- EndTxnResponse.java
- EnvelopeRequest.java
- EnvelopeResponse.java
- ExpireDelegationTokenRequest.java
- ExpireDelegationTokenResponse.java
- FetchMetadata.java
- FetchRequest.java
- FetchResponse.java
- FetchSnapshotRequest.java
- FetchSnapshotResponse.java
- FindCoordinatorRequest.java
- FindCoordinatorResponse.java
- GetTelemetrySubscriptionsRequest.java
- GetTelemetrySubscriptionsResponse.java
- HeartbeatRequest.java
- HeartbeatResponse.java
- IncrementalAlterConfigsRequest.java
- IncrementalAlterConfigsResponse.java
- InitializeShareGroupStateRequest.java
- InitializeShareGroupStateResponse.java
- InitProducerIdRequest.java
- InitProducerIdResponse.java
- JoinGroupRequest.java
- JoinGroupResponse.java
- LeaveGroupRequest.java
- LeaveGroupResponse.java
- ListConfigResourcesRequest.java
- ListConfigResourcesResponse.java
- ListGroupsRequest.java
- ListGroupsResponse.java
- ListOffsetsRequest.java
- ListOffsetsResponse.java
- ListPartitionReassignmentsRequest.java
- ListPartitionReassignmentsResponse.java
- ListTransactionsRequest.java
- ListTransactionsResponse.java
- MetadataRequest.java
- MetadataResponse.java
- OffsetCommitRequest.java
- OffsetCommitResponse.java
- OffsetDeleteRequest.java
- OffsetDeleteResponse.java
- OffsetFetchRequest.java
- OffsetFetchResponse.java
- OffsetsForLeaderEpochRequest.java
- OffsetsForLeaderEpochResponse.java
- package-info.java
- ProduceRequest.java
- ProduceResponse.java
- PushTelemetryRequest.java
- PushTelemetryResponse.java
- ReadShareGroupStateRequest.java
- ReadShareGroupStateResponse.java
- ReadShareGroupStateSummaryRequest.java
- ReadShareGroupStateSummaryResponse.java
- RemoveRaftVoterRequest.java
- RemoveRaftVoterResponse.java
- RenewDelegationTokenRequest.java
- RenewDelegationTokenResponse.java
- RequestAndSize.java
- RequestContext.java
- RequestHeader.java
- RequestUtils.java
- ResponseHeader.java
- SaslAuthenticateRequest.java
- SaslAuthenticateResponse.java
- SaslHandshakeRequest.java
- SaslHandshakeResponse.java
- ShareAcknowledgeRequest.java
- ShareAcknowledgeResponse.java
- ShareFetchRequest.java
- ShareFetchResponse.java
- ShareGroupDescribeRequest.java
- ShareGroupDescribeResponse.java
- ShareGroupHeartbeatRequest.java
- ShareGroupHeartbeatResponse.java
- ShareRequestMetadata.java
- StreamsGroupDescribeRequest.java
- StreamsGroupDescribeResponse.java
- StreamsGroupHeartbeatRequest.java
- StreamsGroupHeartbeatResponse.java
- StreamsGroupTopologyDescriptionUpdateRequest.java
- StreamsGroupTopologyDescriptionUpdateResponse.java
- SyncGroupRequest.java
- SyncGroupResponse.java
- TransactionResult.java
- TxnOffsetCommitRequest.java
- TxnOffsetCommitResponse.java
- UnregisterBrokerRequest.java
- UnregisterBrokerResponse.java
- UnregisterControllerRequest.java
- UnregisterControllerResponse.java
- UpdateFeaturesRequest.java
- UpdateFeaturesResponse.java
- UpdateRaftVoterRequest.java
- UpdateRaftVoterResponse.java
- VoteRequest.java
- VoteResponse.java
- WriteShareGroupStateRequest.java
- WriteShareGroupStateResponse.java
- WriteTxnMarkersRequest.java
- WriteTxnMarkersResponse.java
- package-info.java
- PatternType.java
- Resource.java
- ResourcePattern.java
- ResourcePatternFilter.java
- ResourceType.java
- AuthenticateCallbackHandler.java
- AuthenticationContext.java
- KafkaPrincipal.java
- KafkaPrincipalBuilder.java
- KafkaPrincipalSerde.java
- Login.java
- package-info.java
- PlaintextAuthenticationContext.java
- SaslAuthenticationContext.java
- SaslExtensions.java
- SaslExtensionsCallback.java
- SecurityProtocol.java
- SecurityProviderCreator.java
- SslAuthenticationContext.java
- SslEngineFactory.java
- AbstractLogin.java
- CredentialCache.java
- DefaultKafkaPrincipalBuilder.java
- DefaultLogin.java
- LoginManager.java
- package-info.java
- SaslClientAuthenticator.java
- SaslClientCallbackHandler.java
- SaslInternalConfigs.java
- SaslServerAuthenticator.java
- SaslServerCallbackHandler.java
- BadFormatString.java
- KerberosClientCallbackHandler.java
- KerberosError.java
- KerberosLogin.java
- KerberosName.java
- KerberosRule.java
- KerberosShortNamer.java
- NoMatchingRule.java
- package-info.java
- ExpiringCredential.java
- ExpiringCredentialRefreshConfig.java
- ExpiringCredentialRefreshingLogin.java
- AssertionCreator.java
- AssertionJwtTemplate.java
- AssertionSupplierFactory.java
- AssertionUtils.java
- CloseableSupplier.java
- DefaultAssertionCreator.java
- DynamicAssertionJwtTemplate.java
- FileAssertionCreator.java
- FileAssertionJwtTemplate.java
- LayeredAssertionJwtTemplate.java
- StaticAssertionJwtTemplate.java
- BasicOAuthBearerToken.java
- CachedFile.java
- ClaimValidationUtils.java
- ClientAssertionRequestFormatter.java
- ClientCredentialsRequestFormatterFactory.java
- ClientSecretRequestFormatter.java
- CloseableVerificationKeyResolver.java
- ConfigOrJaas.java
- ConfigurationUtils.java
- HttpJwtRetriever.java
- HttpRequestFormatter.java
- JaasOptionsUtils.java
- JwksFileVerificationKeyResolver.java
- JwtBearerRequestFormatter.java
- JwtResponseParser.java
- OAuthBearerConfigurable.java
- RefreshingHttpsJwks.java
- RefreshingHttpsJwksVerificationKeyResolver.java
- Retry.java
- Retryable.java
- SerializedJwt.java
- UnretryableException.java
- VerificationKeyResolverFactory.java
- OAuthBearerConfigException.java
- OAuthBearerIllegalTokenException.java
- OAuthBearerScopeUtils.java
- OAuthBearerUnsecuredJws.java
- OAuthBearerUnsecuredLoginCallbackHandler.java
- OAuthBearerUnsecuredValidatorCallbackHandler.java
- OAuthBearerValidationResult.java
- OAuthBearerValidationUtils.java
- OAuthBearerClientInitialResponse.java
- OAuthBearerRefreshingLogin.java
- OAuthBearerSaslClient.java
- OAuthBearerSaslClientCallbackHandler.java
- OAuthBearerSaslClientProvider.java
- OAuthBearerSaslServer.java
- OAuthBearerSaslServerProvider.java
- BrokerJwtValidator.java
- ClientCredentialsJwtRetriever.java
- ClientJwtValidator.java
- DefaultJwtRetriever.java
- DefaultJwtValidator.java
- FileJwtRetriever.java
- JwtBearerJwtRetriever.java
- JwtRetriever.java
- JwtRetrieverException.java
- JwtValidator.java
- JwtValidatorException.java
- OAuthBearerExtensionsValidatorCallback.java
- OAuthBearerLoginCallbackHandler.java
- OAuthBearerLoginModule.java
- OAuthBearerToken.java
- OAuthBearerTokenCallback.java
- OAuthBearerValidatorCallback.java
- OAuthBearerValidatorCallbackHandler.java
- package-info.java
- PlainSaslServer.java
- PlainSaslServerProvider.java
- PlainServerCallbackHandler.java
- package-info.java
- PlainAuthenticateCallback.java
- PlainLoginModule.java
- ScramCredentialUtils.java
- ScramExtensions.java
- ScramFormatter.java
- ScramMechanism.java
- ScramMessages.java
- ScramSaslClient.java
- ScramSaslClientProvider.java
- ScramSaslServer.java
- ScramSaslServerProvider.java
- ScramServerCallbackHandler.java
- package-info.java
- ScramCredential.java
- ScramCredentialCallback.java
- ScramExtensionsCallback.java
- ScramLoginModule.java
- CommonNameLoggingSslEngineFactory.java
- CommonNameLoggingTrustManagerFactoryWrapper.java
- DefaultSslEngineFactory.java
- package-info.java
- SslFactory.java
- SslPrincipalMapper.java
- DelegationTokenCache.java
- DelegationTokenCredentialCallback.java
- DelegationToken.java
- package-info.java
- TokenInformation.java
- JaasConfig.java
- JaasContext.java
- JaasUtils.java
- package-info.java
- BooleanDeserializer.java
- BooleanSerializer.java
- ByteArrayDeserializer.java
- ByteArraySerializer.java
- ByteBufferDeserializer.java
- ByteBufferSerializer.java
- BytesDeserializer.java
- BytesSerializer.java
- Deserializer.java
- DoubleDeserializer.java
- DoubleSerializer.java
- FloatDeserializer.java
- FloatSerializer.java
- IntegerDeserializer.java
- IntegerSerializer.java
- ListDeserializer.java
- ListSerializer.java
- LongDeserializer.java
- LongSerializer.java
- package-info.java
- Serde.java
- Serdes.java
- Serializer.java
- ShortDeserializer.java
- ShortSerializer.java
- StringDeserializer.java
- StringSerializer.java
- UUIDDeserializer.java
- UUIDSerializer.java
- VoidDeserializer.java
- VoidSerializer.java
- ClientTelemetryEmitter.java
- ClientTelemetryProvider.java
- ClientTelemetryReporter.java
- ClientTelemetrySender.java
- ClientTelemetryUtils.java
- KafkaMetricsCollector.java
- LastValueTracker.java
- MetricKey.java
- MetricKeyable.java
- MetricNamingStrategy.java
- MetricsCollector.java
- MetricsEmitter.java
- SinglePointMetric.java
- TelemetryMetricNamingConvention.java
- ClientTelemetryState.java
- AbstractIterator.java
- AppInfoParser.java
- BufferSupplier.java
- ByteBufferInputStream.java
- ByteBufferOutputStream.java
- ByteBufferUnmapper.java
- ByteUtils.java
- Checksums.java
- ChildFirstClassLoader.java
- ChunkedBytesStream.java
- CircularIterator.java
- CloseableIterator.java
- ConfigUtils.java
- CopyOnWriteMap.java
- Crc32C.java
- Exit.java
- ExponentialBackoff.java
- ExponentialBackoffManager.java
- FixedOrderMap.java
- ImplicitLinkedHashCollection.java
- ImplicitLinkedHashMultiCollection.java
- Java.java
- KafkaThread.java
- LogContext.java
- LoggingSignalHandler.java
- OperatingSystem.java
- PrimitiveRef.java
- ProducerIdAndEpoch.java
- Sanitizer.java
- SecurityUtils.java
- Shell.java
- SingleByteBufferOutputStream.java
- ThreadUtils.java
- Bytes.java
- package-info.java
- SystemTime.java
- Time.java
- Timer.java
- Utils.java
- ClassicGroupState.java
- Cluster.java
- ClusterResource.java
- ClusterResourceListener.java
- Configurable.java
- ConsumerGroupState.java
- ElectionType.java
- Endpoint.java
- GroupState.java
- GroupType.java
- InvalidRecordException.java
- IsolationLevel.java
- KafkaException.java
- KafkaFuture.java
- MessageFormatter.java
- Metric.java
- MetricName.java
- MetricNameTemplate.java
- Node.java
- package-info.java
- PartitionInfo.java
- Reconfigurable.java
- TopicCollection.java
- TopicIdPartition.java
- TopicPartition.java
- TopicPartitionInfo.java
- TopicPartitionReplica.java
- Uuid.java
- CidrUtils.java
- AclCreateResult.java
- AclDeleteResult.java
- Action.java
- AuthorizableRequestContext.java
- AuthorizationResult.java
- Authorizer.java
- AuthorizerServerInfo.java
- package-info.java
- AlterConfigPolicy.java
- CreateTopicPolicy.java
- package-info.java
- ClientQuotaCallback.java
- ClientQuotaEntity.java
- ClientQuotaType.java
- package-info.java
- ClientTelemetry.java
- ClientTelemetryContext.java
- ClientTelemetryExporter.java
- ClientTelemetryExporterProvider.java
- ClientTelemetryPayload.java
- ClientTelemetryReceiver.java
- package-info.java
- AbortedTxn.json
- AddOffsetsToTxnRequest.json
- AddOffsetsToTxnResponse.json
- AddPartitionsToTxnRequest.json
- AddPartitionsToTxnResponse.json
- AddRaftVoterRequest.json
- AddRaftVoterResponse.json
- AllocateProducerIdsRequest.json
- AllocateProducerIdsResponse.json
- AlterClientQuotasRequest.json
- AlterClientQuotasResponse.json
- AlterConfigsRequest.json
- AlterConfigsResponse.json
- AlterPartitionReassignmentsRequest.json
- AlterPartitionReassignmentsResponse.json
- AlterPartitionRequest.json
- AlterPartitionResponse.json
- AlterReplicaLogDirsRequest.json
- AlterReplicaLogDirsResponse.json
- AlterShareGroupOffsetsRequest.json
- AlterShareGroupOffsetsResponse.json
- AlterUserScramCredentialsRequest.json
- AlterUserScramCredentialsResponse.json
- ApiVersionsRequest.json
- ApiVersionsResponse.json
- AssignReplicasToDirsRequest.json
- AssignReplicasToDirsResponse.json
- BeginQuorumEpochRequest.json
- BeginQuorumEpochResponse.json
- BrokerHeartbeatRequest.json
- BrokerHeartbeatResponse.json
- BrokerRegistrationRequest.json
- BrokerRegistrationResponse.json
- ConsumerGroupDescribeRequest.json
- ConsumerGroupDescribeResponse.json
- ConsumerGroupHeartbeatRequest.json
- ConsumerGroupHeartbeatResponse.json
- ConsumerProtocolAssignment.json
- ConsumerProtocolSubscription.json
- ControlledShutdownRequest.json
- ControlledShutdownResponse.json
- ControllerRegistrationRequest.json
- ControllerRegistrationResponse.json
- ControlRecordTypeSchema.json
- CreateAclsRequest.json
- CreateAclsResponse.json
- CreateDelegationTokenRequest.json
- CreateDelegationTokenResponse.json
- CreatePartitionsRequest.json
- CreatePartitionsResponse.json
- CreateTopicsRequest.json
- CreateTopicsResponse.json
- DefaultPrincipalData.json
- DeleteAclsRequest.json
- DeleteAclsResponse.json
- DeleteGroupsRequest.json
- DeleteGroupsResponse.json
- DeleteRecordsRequest.json
- DeleteRecordsResponse.json
- DeleteShareGroupOffsetsRequest.json
- DeleteShareGroupOffsetsResponse.json
- DeleteShareGroupStateRequest.json
- DeleteShareGroupStateResponse.json
- DeleteTopicsRequest.json
- DeleteTopicsResponse.json
- DescribeAclsRequest.json
- DescribeAclsResponse.json
- DescribeClientQuotasRequest.json
- DescribeClientQuotasResponse.json
- DescribeClusterRequest.json
- DescribeClusterResponse.json
- DescribeConfigsRequest.json
- DescribeConfigsResponse.json
- DescribeDelegationTokenRequest.json
- DescribeDelegationTokenResponse.json
- DescribeGroupsRequest.json
- DescribeGroupsResponse.json
- DescribeLogDirsRequest.json
- DescribeLogDirsResponse.json
- DescribeProducersRequest.json
- DescribeProducersResponse.json
- DescribeQuorumRequest.json
- DescribeQuorumResponse.json
- DescribeShareGroupOffsetsRequest.json
- DescribeShareGroupOffsetsResponse.json
- DescribeTopicPartitionsRequest.json
- DescribeTopicPartitionsResponse.json
- DescribeTransactionsRequest.json
- DescribeTransactionsResponse.json
- DescribeUserScramCredentialsRequest.json
- DescribeUserScramCredentialsResponse.json
- ElectLeadersRequest.json
- ElectLeadersResponse.json
- EndQuorumEpochRequest.json
- EndQuorumEpochResponse.json
- EndTxnMarker.json
- EndTxnRequest.json
- EndTxnResponse.json
- EnvelopeRequest.json
- EnvelopeResponse.json
- ExpireDelegationTokenRequest.json
- ExpireDelegationTokenResponse.json
- FetchRequest.json
- FetchResponse.json
- FetchSnapshotRequest.json
- FetchSnapshotResponse.json
- FindCoordinatorRequest.json
- FindCoordinatorResponse.json
- GetTelemetrySubscriptionsRequest.json
- GetTelemetrySubscriptionsResponse.json
- HeartbeatRequest.json
- HeartbeatResponse.json
- IncrementalAlterConfigsRequest.json
- IncrementalAlterConfigsResponse.json
- InitializeShareGroupStateRequest.json
- InitializeShareGroupStateResponse.json
- InitProducerIdRequest.json
- InitProducerIdResponse.json
- JoinGroupRequest.json
- JoinGroupResponse.json
- KRaftVersionRecord.json
- LeaderAndIsrRequest.json
- LeaderAndIsrResponse.json
- LeaderChangeMessage.json
- LeaveGroupRequest.json
- LeaveGroupResponse.json
- ListConfigResourcesRequest.json
- ListConfigResourcesResponse.json
- ListGroupsRequest.json
- ListGroupsResponse.json
- ListOffsetsRequest.json
- ListOffsetsResponse.json
- ListPartitionReassignmentsRequest.json
- ListPartitionReassignmentsResponse.json
- ListTransactionsRequest.json
- ListTransactionsResponse.json
- MetadataRequest.json
- MetadataResponse.json
- OffsetCommitRequest.json
- OffsetCommitResponse.json
- OffsetDeleteRequest.json
- OffsetDeleteResponse.json
- OffsetFetchRequest.json
- OffsetFetchResponse.json
- OffsetForLeaderEpochRequest.json
- OffsetForLeaderEpochResponse.json
- ProduceRequest.json
- ProduceResponse.json
- PushTelemetryRequest.json
- PushTelemetryResponse.json
- README.md
- ReadShareGroupStateRequest.json
- ReadShareGroupStateResponse.json
- ReadShareGroupStateSummaryRequest.json
- ReadShareGroupStateSummaryResponse.json
- RemoveRaftVoterRequest.json
- RemoveRaftVoterResponse.json
- RenewDelegationTokenRequest.json
- RenewDelegationTokenResponse.json
- RequestHeader.json
- ResponseHeader.json
- SaslAuthenticateRequest.json
- SaslAuthenticateResponse.json
- SaslHandshakeRequest.json
- SaslHandshakeResponse.json
- ShareAcknowledgeRequest.json
- ShareAcknowledgeResponse.json
- ShareFetchRequest.json
- ShareFetchResponse.json
- ShareGroupDescribeRequest.json
- ShareGroupDescribeResponse.json
- ShareGroupHeartbeatRequest.json
- ShareGroupHeartbeatResponse.json
- SnapshotFooterRecord.json
- SnapshotHeaderRecord.json
- StopReplicaRequest.json
- StopReplicaResponse.json
- StreamsGroupDescribeRequest.json
- StreamsGroupDescribeResponse.json
- StreamsGroupHeartbeatRequest.json
- StreamsGroupHeartbeatResponse.json
- StreamsGroupTopologyDescriptionUpdateRequest.json
- StreamsGroupTopologyDescriptionUpdateResponse.json
- SyncGroupRequest.json
- SyncGroupResponse.json
- TxnOffsetCommitRequest.json
- TxnOffsetCommitResponse.json
- UnregisterBrokerRequest.json
- UnregisterBrokerResponse.json
- UnregisterControllerRequest.json
- UnregisterControllerResponse.json
- UpdateFeaturesRequest.json
- UpdateFeaturesResponse.json
- UpdateMetadataRequest.json
- UpdateMetadataResponse.json
- UpdateRaftVoterRequest.json
- UpdateRaftVoterResponse.json
- VoteRequest.json
- VoteResponse.json
- VotersRecord.json
- WriteShareGroupStateRequest.json
- WriteShareGroupStateResponse.json
- WriteTxnMarkersRequest.json
- WriteTxnMarkersResponse.json
- org.apache.kafka.common.config.provider.ConfigProvider
- AbortTransactionHandlerTest.java
- AdminApiDriverTest.java
- AdminFetchMetricsManagerTest.java
- AdminMetadataManagerTest.java
- AllBrokersStrategyIntegrationTest.java
- AllBrokersStrategyTest.java
- AlterConsumerGroupOffsetsHandlerTest.java
- CoordinatorStrategyTest.java
- DeleteConsumerGroupOffsetsHandlerTest.java
- DeleteConsumerGroupsHandlerTest.java
- DeleteGroupsHandlerTest.java
- DeleteRecordsHandlerTest.java
- DeleteShareGroupsHandlerTest.java
- DescribeConsumerGroupsHandlerTest.java
- DescribeProducersHandlerTest.java
- DescribeStreamsGroupsHandlerTest.java
- DescribeTransactionsHandlerTest.java
- FenceProducersHandlerTest.java
- ListConsumerGroupOffsetsHandlerTest.java
- ListOffsetsHandlerTest.java
- ListTransactionsHandlerTest.java
- PartitionLeaderStrategyIntegrationTest.java
- PartitionLeaderStrategyTest.java
- RemoveMembersFromConsumerGroupHandlerTest.java
- AdminClientConfigTest.java
- ConsumerGroupDescriptionTest.java
- ConsumerGroupListingTest.java
- DeleteConsumerGroupOffsetsResultTest.java
- DeleteTopicsResultTest.java
- DescribeTopicsResultTest.java
- DescribeUserScramCredentialsResultTest.java
- EndpointTypeTest.java
- GroupListingTest.java
- KafkaAdminClientConfigTest.java
- KafkaAdminClientConsumerGroupTest.java
- KafkaAdminClientShareGroupTest.java
- KafkaAdminClientStreamsGroupTest.java
- KafkaAdminClientTest.java
- KafkaAdminClientTestBase.java
- KafkaAdminClientTopicTest.java
- KafkaAdminClientTransactionTest.java
- ListConsumerGroupsOptionsTest.java
- ListGroupsOptionsTest.java
- ListTransactionsResultTest.java
- MemberDescriptionTest.java
- MockAdminClientTest.java
- NewTopicTest.java
- RaftVoterEndpointTest.java
- RemoveMembersFromConsumerGroupOptionsTest.java
- RemoveMembersFromConsumerGroupResultTest.java
- ScramMechanismTest.java
- TopicCollectionTest.java
- ApplicationEventProcessorTest.java
- CompletableEventReaperTest.java
- AbstractConsumerMetricsManagerTest.java
- AsyncConsumerMetricsTest.java
- ConsumerRebalanceMetricsManagerTest.java
- HeartbeatMetricsManagerTest.java
- OffsetCommitMetricsManagerTest.java
- RebalanceCallbackMetricsManagerTest.java
- ShareRebalanceMetricsManagerTest.java
- AbstractCoordinatorTest.java
- AbstractHeartbeatRequestManagerTest.java
- AbstractPartitionAssignorTest.java
- AbstractStickyAssignorTest.java
- AcknowledgementCommitCallbackHandlerTest.java
- AcknowledgementsTest.java
- ApplicationEventHandlerTest.java
- AsyncKafkaConsumerTest.java
- AutoOffsetResetStrategyTest.java
- BackgroundEventHandlerTest.java
- BaseHeartbeatThreadTest.java
- CommitRequestManagerTest.java
- CompletedFetchTest.java
- ConsumerCoordinatorTest.java
- ConsumerHeartbeatRequestManagerTest.java
- ConsumerInterceptorsTest.java
- ConsumerMembershipManagerTest.java
- ConsumerMetadataTest.java
- ConsumerNetworkClientTest.java
- ConsumerNetworkThreadTest.java
- ConsumerProtocolTest.java
- CooperativeConsumerCoordinatorTest.java
- CoordinatorRequestManagerTest.java
- CounterConsumerRebalanceListener.java
- DelegatingRebalanceConsumerTest.java
- EagerConsumerCoordinatorTest.java
- FetchBufferTest.java
- FetchCollectorTest.java
- FetchConfigTest.java
- FetcherTest.java
- FetchMetricsManagerTest.java
- FetchRequestManagerTest.java
- FetchTest.java
- GroupCoordinatorNodeTest.java
- HeartbeatRequestStateTest.java
- HeartbeatTest.java
- KafkaConsumerMetricsTest.java
- MockPartitionAssignor.java
- NetworkClientDelegateTest.java
- OffsetCommitCallbackInvokerTest.java
- OffsetFetcherTest.java
- OffsetForLeaderEpochClientTest.java
- OffsetsRequestManagerTest.java
- RequestFutureTest.java
- RequestManagersTest.java
- RequestStateTest.java
- ShareAcknowledgementModeTest.java
- ShareAcquireModeTest.java
- ShareCompletedFetchTest.java
- ShareConsumeRequestManagerTest.java
- ShareConsumerImplTest.java
- ShareFetchBufferTest.java
- ShareFetchCollectorTest.java
- ShareFetchMetricsManagerTest.java
- ShareHeartbeatRequestManagerTest.java
- ShareMembershipManagerTest.java
- ShareSessionHandlerTest.java
- StreamsGroupHeartbeatRequestManagerTest.java
- StreamsGroupTopologyDescriptionRequestManagerTest.java
- StreamsMembershipManagerTest.java
- StreamsRebalanceDataTest.java
- StreamsRebalanceListenerInvokerTest.java
- SubscriptionStateTest.java
- ThrowOnAssignmentAssignor.java
- TimedRequestStateTest.java
- TopicIdPartitionSetTest.java
- TopicMetadataFetcherTest.java
- TopicMetadataRequestManagerTest.java
- TopicPartitionComparatorTest.java
- WakeupTriggerTest.java
- CloseOptionsTest.java
- ConsumerConfigTest.java
- ConsumerGroupMetadataTest.java
- ConsumerPartitionAssignorTest.java
- ConsumerRebalanceListenerTest.java
- ConsumerRecordsTest.java
- ConsumerRecordTest.java
- CooperativeStickyAssignorTest.java
- KafkaConsumerTest.java
- KafkaShareConsumerMetricsTest.java
- KafkaShareConsumerTest.java
- MockConsumerTest.java
- MockShareConsumerTest.java
- OffsetAndMetadataTest.java
- RangeAssignorTest.java
- RebalanceListenerTest.java
- RoundRobinAssignorTest.java
- ShareConsumerConfigTest.java
- StickyAssignorTest.java
- BufferPoolChunkAllocationTest.java
- BufferPoolTest.java
- BuiltInPartitionerTest.java
- ChunkedByteBufferOutputStreamTest.java
- ChunkedRecordAccumulatorTest.java
- FutureRecordMetadataTest.java
- KafkaProducerMetricsTest.java
- ProducerBatchTest.java
- ProducerInterceptorsTest.java
- ProducerMetadataTest.java
- ProducerTestUtils.java
- RecordAccumulatorTest.java
- SenderTest.java
- TransactionManagerTest.java
- KafkaProducerTest.java
- MockProducerTest.java
- PreparedTxnStateTest.java
- ProducerConfigTest.java
- ProducerRecordTest.java
- RecordMetadataTest.java
- RecordSendTest.java
- RoundRobinPartitionerTest.java
- AddressChangeHostResolver.java
- ApiVersionsTest.java
- ClientUtilsTest.java
- ClusterConnectionStatesTest.java
- CommonClientConfigsTest.java
- FetchSessionHandlerTest.java
- GroupRebalanceConfigTest.java
- InFlightRequestsTest.java
- MetadataSnapshotTest.java
- MetadataTest.java
- NetworkClientTest.java
- NodeApiVersionsTest.java
- AclBindingTest.java
- AclOperationTest.java
- AclPermissionTypeTest.java
- ResourcePatternFilterTest.java
- ResourcePatternTest.java
- LRUCacheTest.java
- GzipCompressionTest.java
- Lz4CompressionTest.java
- NoCompressionTest.java
- SnappyCompressionTest.java
- ZstdCompressionTest.java
- AllowedPathsTest.java
- DirectoryConfigProviderTest.java
- EnvVarConfigProviderTest.java
- FileConfigProviderTest.java
- MockVaultConfigProvider.java
- AbstractConfigTest.java
- ConfigDefTest.java
- ConfigResourceTest.java
- ConfigTransformerTest.java
- SaslConfigsTest.java
- TransactionExceptionHierarchyTest.java
- FeaturesTest.java
- SupportedVersionRangeTest.java
- RecordHeadersTest.java
- IdempotentCloserTest.java
- PartitionStatesTest.java
- PluginTest.java
- SecurityManagerCompatibilityTest.java
- TopicTest.java
- UnsupportedProtocolFieldExceptionTest.java
- GarbageCollectedMemoryPoolTest.java
- ApiMessageTypeTest.java
- MessageTest.java
- NullableStructMessageTest.java
- ProtocolRoundTripConsistencyTest.java
- RecordsSerdeTest.java
- SimpleArraysMessageTest.java
- SimpleExampleMessageTest.java
- IntGaugeSuiteTest.java
- MetricsUtilsTest.java
- PluginMetricsImplTest.java
- FrequenciesTest.java
- HistogramTest.java
- MeterTest.java
- RateTest.java
- SampledStatTest.java
- JmxReporterTest.java
- KafkaMbeanTest.java
- KafkaMetricsContextTest.java
- KafkaMetricTest.java
- MetricsTest.java
- SampleMetrics.java
- SensorTest.java
- TokenBucketTest.java
- ChannelBuildersTest.java
- DefaultChannelMetadataRegistry.java
- EchoServer.java
- KafkaChannelTest.java
- NetworkReceiveTest.java
- PlaintextSender.java
- SaslChannelBuilderTest.java
- SelectorTest.java
- ServerConnectionIdTest.java
- SslSelectorTest.java
- SslSender.java
- SslTransportLayerTest.java
- SslTransportTls12Tls13Test.java
- SslVersionsTransportLayerTest.java
- Tls12SelectorTest.java
- Tls13SelectorTest.java
- ProtocolSerializationTest.java
- RawTaggedFieldWriterTest.java
- StructTest.java
- TypeTest.java
- ApiKeysTest.java
- ByteBufferAccessorTest.java
- DataOutputStreamWritableTest.java
- ErrorsTest.java
- MessageUtilTest.java
- ProtocolTest.java
- ProtoUtilsTest.java
- SendBuilderTest.java
- AbstractLegacyRecordBatchTest.java
- BufferSupplierTest.java
- ByteBufferLogInputStreamTest.java
- CompressionRatioEstimatorTest.java
- ControlRecordTypeTest.java
- ControlRecordUtilsTest.java
- DefaultRecordBatchTest.java
- DefaultRecordTest.java
- EndTransactionMarkerTest.java
- FileLogInputStreamTest.java
- FileRecordsTest.java
- LegacyRecordTest.java
- MemoryRecordsBuilderTest.java
- MemoryRecordsTest.java
- MultiRecordsSendTest.java
- RemoteLogInputStreamTest.java
- SimpleLegacyRecordTest.java
- UnalignedFileRecordsTest.java
- ReplicaSelectorTest.java
- AddPartitionsToTxnRequestTest.java
- AddPartitionsToTxnResponseTest.java
- AlterPartitionRequestTest.java
- AlterReplicaLogDirsRequestTest.java
- AlterReplicaLogDirsResponseTest.java
- ApiErrorTest.java
- ApiVersionsResponseTest.java
- BrokerRegistrationRequestTest.java
- ByteBufferChannelTest.java
- ConsumerGroupDescribeRequestTest.java
- ConsumerGroupDescribeResponseTest.java
- CreateAclsRequestTest.java
- DeleteAclsRequestTest.java
- DeleteAclsResponseTest.java
- DeleteGroupsRequestTest.java
- DeleteGroupsResponseTest.java
- DeleteTopicsRequestTest.java
- DescribeAclsRequestTest.java
- DescribeAclsResponseTest.java
- DescribeGroupsRequestTest.java
- EndTxnRequestTest.java
- EndTxnResponseTest.java
- EnvelopeRequestTest.java
- EnvelopeResponseTest.java
- FetchRequestTest.java
- FindCoordinatorRequestTest.java
- GetTelemetrySubscriptionsRequestTest.java
- GetTelemetrySubscriptionsResponseTest.java
- HeartbeatRequestTest.java
- JoinGroupRequestTest.java
- JoinGroupResponseTest.java
- LeaveGroupRequestTest.java
- LeaveGroupResponseTest.java
- ListOffsetsRequestTest.java
- MetadataRequestTest.java
- MetadataResponseTest.java
- OffsetCommitRequestTest.java
- OffsetCommitResponseTest.java
- OffsetFetchRequestTest.java
- OffsetFetchResponseTest.java
- OffsetsForLeaderEpochRequestTest.java
- ProduceRequestTest.java
- ProduceResponseTest.java
- PushTelemetryRequestTest.java
- PushTelemetryResponseTest.java
- RequestContextTest.java
- RequestHeaderTest.java
- RequestResponseTest.java
- RequestUtilsTest.java
- StreamsGroupHeartbeatRequestTest.java
- StreamsGroupHeartbeatResponseTest.java
- SyncGroupRequestTest.java
- TxnOffsetCommitRequestTest.java
- TxnOffsetCommitResponseTest.java
- UpdateFeaturesRequestTest.java
- UpdateFeaturesResponseTest.java
- WriteTxnMarkersRequestTest.java
- WriteTxnMarkersResponseTest.java
- ResourceTypeTest.java
- DefaultKafkaPrincipalBuilderTest.java
- KafkaPrincipalTest.java
- ClientAuthenticationFailureTest.java
- LoginManagerTest.java
- SaslAuthenticatorFailureDelayTest.java
- SaslAuthenticatorFailureNoDelayTest.java
- SaslAuthenticatorFailurePositiveDelayTest.java
- SaslAuthenticatorTest.java
- SaslServerAuthenticatorTest.java
- KerberosNameTest.java
- KerberosRuleTest.java
- ExpiringCredentialRefreshConfigTest.java
- ExpiringCredentialRefreshingLoginTest.java
- AssertionSupplierFactoryTest.java
- AssertionUtilsTest.java
- DefaultAssertionCreatorTest.java
- DynamicAssertionJwtTemplateTest.java
- FileAssertionCreatorTest.java
- FileAssertionJwtTemplateTest.java
- AccessTokenBuilder.java
- BasicOAuthBearerTokenTest.java
- CachedFileTest.java
- ClientAssertionRequestFormatterTest.java
- ClientCredentialsRequestFormatterFactoryTest.java
- ClientSecretRequestFormatterTest.java
- ConfigOrJaasTest.java
- ConfigurationUtilsTest.java
- HttpJwtRetrieverTest.java
- JaasOptionsUtilsTest.java
- JwtResponseParserTest.java
- OAuthBearerTest.java
- RefreshingHttpsJwksTest.java
- RetryTest.java
- VerificationKeyResolverFactoryTest.java
- OAuthBearerScopeUtilsTest.java
- OAuthBearerUnsecuredJwsTest.java
- OAuthBearerUnsecuredLoginCallbackHandlerTest.java
- OAuthBearerUnsecuredValidatorCallbackHandlerTest.java
- OAuthBearerValidationUtilsTest.java
- OAuthBearerClientInitialResponseTest.java
- OAuthBearerSaslClientTest.java
- OAuthBearerSaslServerTest.java
- BrokerJwtValidatorTest.java
- ClaimValidationUtilsTest.java
- ClientAssertionKeycloakIntegrationTest.java
- ClientJwtValidatorTest.java
- DefaultJwtRetrieverTest.java
- DefaultJwtValidatorTest.java
- JwtBearerJwtRetrieverTest.java
- JwtValidatorTest.java
- OAuthBearerExtensionsValidatorCallbackTest.java
- OAuthBearerLoginCallbackHandlerTest.java
- OAuthBearerLoginModuleTest.java
- OAuthBearerSaslClientCallbackHandlerTest.java
- OAuthBearerTokenCallbackTest.java
- OAuthBearerTokenMock.java
- OAuthBearerValidatorCallbackHandlerTest.java
- OAuthBearerValidatorCallbackTest.java
- PlainSaslServerTest.java
- ScramCredentialUtilsTest.java
- ScramFormatterTest.java
- ScramMessagesTest.java
- ScramSaslServerTest.java
- TestKeyManagerFactory.java
- TestPlainSaslServerProvider.java
- TestPlainSaslServerProviderCreator.java
- TestProvider.java
- TestProviderCreator.java
- TestScramSaslServerProvider.java
- TestScramSaslServerProviderCreator.java
- TestTrustManagerFactory.java
- CommonNameLoggingSslEngineFactoryTest.java
- CommonNameLoggingTrustManagerFactoryWrapperTest.java
- DefaultSslEngineFactoryTest.java
- SslFactoryTest.java
- SslPrincipalMapperTest.java
- Tls12SslFactoryTest.java
- Tls13SslFactoryTest.java
- JaasContextTest.java
- SaslExtensionsTest.java
- ListDeserializerTest.java
- ListSerializerTest.java
- SerializationTest.java
- ClientTelemetryEmitterTest.java
- ClientTelemetryReporterTest.java
- ClientTelemetryUtilsTest.java
- KafkaMetricsCollectorTest.java
- LastValueTrackerTest.java
- SinglePointMetricTest.java
- TelemetryMetricNamingConventionTest.java
- TestEmitter.java
- ClientTelemetryStateTest.java
- ApiKeyVersionsProviderTest.java
- AbstractIteratorTest.java
- AppInfoParserTest.java
- ByteBufferInputStreamTest.java
- ByteBufferUnmapperTest.java
- ByteUtilsTest.java
- ChecksumsTest.java
- ChunkedBytesStreamTest.java
- CircularIteratorTest.java
- ConfigUtilsTest.java
- Crc32CTest.java
- ExitTest.java
- ExponentialBackoffManagerTest.java
- ExponentialBackoffTest.java
- FixedOrderMapTest.java
- ImplicitLinkedHashCollectionTest.java
- ImplicitLinkedHashMultiCollectionTest.java
- JavaTest.java
- LoggingSignalHandlerTest.java
- PrimitiveRefTest.java
- SanitizerTest.java
- SecurityUtilsTest.java
- ShellTest.java
- SingleByteBufferOutputStreamTest.java
- ThreadUtilsTest.java
- BytesTest.java
- MockTimeTest.java
- Serializer.java
- TimerTest.java
- TimeTest.java
- UtilsTest.java
- ClusterTest.java
- KafkaFutureTest.java
- PartitionInfoTest.java
- TopicIdPartitionTest.java
- TopicPartitionTest.java
- UuidTest.java
- CidrUtilsTest.java
- AlterConfigPolicyTest.java
- DelayedReceive.java
- MetricsBench.java
- MockClusterResourceListener.java
- MockPartitioner.java
- MockSelector.java
- AllTypeMessage.json
- NullableStructMessage.json
- SimpleArraysMessage.json
- SimpleExampleMessage.json
- SimpleRecordsMessage.json
- offsetAndMetadataBeforeLeaderEpoch
- offsetAndMetadataWithLeaderEpoch
- topicPartitionSerializedfile
- log4j2.yaml
- AdminClientTestUtils.java
- AdminClientUnitTestEnv.java
- ConfigTest.java
- FakeForwardingAdmin.java
- MockAdminClient.java
- MockRebalanceListener.java
- MockClient.java
- MockFileConfigProvider.java
- FakeMetricsReporter.java
- CertStores.java
- NetworkTestUtils.java
- NioEchoServer.java
- InvalidMemoryRecordsProvider.java
- ByteBufferChannel.java
- RequestTestUtils.java
- TestDigestLoginModule.java
- TestJaasConfig.java
- TestSecurityConfig.java
- ApiKeyVersionsProvider.java
- ApiKeyVersionsSource.java
- LogCaptureAppender.java
- MockTime.java
- MockConsumerInterceptor.java
- MockDeserializer.java
- MockMetricsReporter.java
- MockProducerInterceptor.java
- MockSerializer.java
- NoRetryException.java
- TestCondition.java
- TestSslUtils.java
- TestUtils.java
- ValuelessCallable.java
- .gitignore
- find-unfinished-test.py
- kafka-merge-pr.py
- README.md
- refresh_collaborators.py
- requirements.txt
- reviewers.py
- update-cache.sh
- verify_license.py
- broker.properties
- connect-console-sink.properties
- connect-console-source.properties
- connect-distributed.properties
- connect-file-sink.properties
- connect-file-source.properties
- connect-log4j2.yaml
- connect-mirror-maker.properties
- connect-standalone.properties
- consumer.properties
- controller.properties
- log4j2.yaml
- producer.properties
- server.properties
- tools-log4j2.yaml
- trogdor.conf
- ConnectPlugin.java
- package-info.java
- Versioned.java
- ConnectorClientConfigOverridePolicy.java
- ConnectorClientConfigRequest.java
- package-info.java
- Connector.java
- ConnectorContext.java
- ConnectRecord.java
- package-info.java
- Task.java
- ConnectSchema.java
- Date.java
- Decimal.java
- Field.java
- package-info.java
- Schema.java
- SchemaAndValue.java
- SchemaBuilder.java
- SchemaProjector.java
- Struct.java
- Time.java
- Timestamp.java
- Values.java
- AlreadyExistsException.java
- ConnectException.java
- DataException.java
- IllegalWorkerStateException.java
- NotFoundException.java
- package-info.java
- RetriableException.java
- SchemaBuilderException.java
- SchemaProjectorException.java
- ConnectHeader.java
- ConnectHeaders.java
- Header.java
- Headers.java
- package-info.java
- AbstractState.java
- ConnectClusterDetails.java
- ConnectClusterState.java
- ConnectorHealth.java
- ConnectorState.java
- ConnectorType.java
- package-info.java
- TaskState.java
- ConnectRestExtension.java
- ConnectRestExtensionContext.java
- package-info.java
- ErrantRecordReporter.java
- package-info.java
- SinkConnector.java
- SinkConnectorContext.java
- SinkRecord.java
- SinkTask.java
- SinkTaskContext.java
- ConnectorTransactionBoundaries.java
- ExactlyOnceSupport.java
- package-info.java
- SourceConnector.java
- SourceConnectorContext.java
- SourceRecord.java
- SourceTask.java
- SourceTaskContext.java
- TransactionContext.java
- Converter.java
- ConverterConfig.java
- ConverterType.java
- HeaderConverter.java
- OffsetStorageReader.java
- package-info.java
- SimpleHeaderConverter.java
- StringConverter.java
- StringConverterConfig.java
- package-info.java
- Predicate.java
- package-info.java
- Transformation.java
- ConnectorUtils.java
- package-info.java
- org.apache.kafka.connect.storage.Converter
- org.apache.kafka.connect.storage.HeaderConverter
- ConnectorReconfigurationTest.java
- ConnectorTest.java
- ConnectSchemaTest.java
- DateTest.java
- DecimalTest.java
- FakeSchema.java
- FieldTest.java
- SchemaBuilderTest.java
- SchemaProjectorTest.java
- StructTest.java
- TimestampTest.java
- TimeTest.java
- ValuesTest.java
- ConnectHeadersTest.java
- ConnectHeaderTest.java
- SinkConnectorTest.java
- SinkRecordTest.java
- SourceConnectorTest.java
- SourceRecordTest.java
- ConverterTypeTest.java
- SimpleHeaderConverterTest.java
- StringConverterTest.java
- ConnectorUtilsTest.java
- org.apache.kafka.connect.sink.SinkConnector
- org.apache.kafka.connect.source.SourceConnector
- .gitignore
- BasicAuthSecurityRestExtension.java
- JaasBasicAuthFilter.java
- PropertyFileLoginModule.java
- org.apache.kafka.connect.rest.ConnectRestExtension
- BasicAuthSecurityRestExtensionTest.java
- JaasBasicAuthFilterTest.java
- .gitignore
- FileStreamSinkConnector.java
- FileStreamSinkTask.java
- FileStreamSourceConnector.java
- FileStreamSourceTask.java
- org.apache.kafka.connect.sink.SinkConnector
- org.apache.kafka.connect.source.SourceConnector
- FileStreamSinkConnectorIntegrationTest.java
- FileStreamSourceConnectorIntegrationTest.java
- FileStreamSinkConnectorTest.java
- FileStreamSinkTaskTest.java
- FileStreamSourceConnectorTest.java
- FileStreamSourceTaskTest.java
- log4j2.yaml
- DecimalFormat.java
- JsonConverter.java
- JsonConverterConfig.java
- JsonDeserializer.java
- JsonSchema.java
- JsonSerializer.java
- org.apache.kafka.connect.storage.Converter
- org.apache.kafka.connect.storage.HeaderConverter
- JsonConverterConfigTest.java
- JsonConverterTest.java
- connect-test.properties
- .gitignore
- CheckpointFormatter.java
- HeartbeatFormatter.java
- OffsetSyncFormatter.java
- InternalMirrorResource.java
- MirrorRestServer.java
- CheckpointStore.java
- ConfigPropertyFilter.java
- DefaultConfigPropertyFilter.java
- DefaultGroupFilter.java
- DefaultTopicFilter.java
- GroupFilter.java
- MirrorCheckpointConfig.java
- MirrorCheckpointConnector.java
- MirrorCheckpointLegacyMetrics.java
- MirrorCheckpointMetrics.java
- MirrorCheckpointTask.java
- MirrorCheckpointTaskConfig.java
- MirrorConnectorConfig.java
- MirrorHeartbeatConfig.java
- MirrorHeartbeatConnector.java
- MirrorHeartbeatTask.java
- MirrorHerder.java
- MirrorMaker.java
- MirrorMakerConfig.java
- MirrorSourceConfig.java
- MirrorSourceConnector.java
- MirrorSourceLegacyMetrics.java
- MirrorSourceMetrics.java
- MirrorSourceTask.java
- MirrorSourceTaskConfig.java
- MirrorUtils.java
- OffsetSync.java
- OffsetSyncStore.java
- OffsetSyncWriter.java
- Scheduler.java
- TopicFilter.java
- org.apache.kafka.connect.source.SourceConnector
- FakeForwardingAdminWithLocalMetadata.java
- FakeLocalMetadataStore.java
- DedicatedMirrorIntegrationTest.java
- IdentityReplicationIntegrationTest.java
- MirrorConnectorsIntegrationBaseTest.java
- MirrorConnectorsIntegrationExactlyOnceTest.java
- MirrorConnectorsIntegrationSSLTest.java
- MirrorConnectorsIntegrationTransactionsTest.java
- MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java
- CheckpointStoreTest.java
- CheckpointTest.java
- HeartbeatTest.java
- MirrorCheckpointConfigTest.java
- MirrorCheckpointConnectorTest.java
- MirrorCheckpointTaskTest.java
- MirrorConnectorConfigTest.java
- MirrorHeartBeatConnectorTest.java
- MirrorHeartbeatTaskTest.java
- MirrorLegacyMetricsTest.java
- MirrorMakerConfigTest.java
- MirrorMetricsTest.java
- MirrorSourceConfigTest.java
- MirrorSourceConnectorTest.java
- MirrorSourceTaskTest.java
- MirrorUtilsTest.java
- OffsetSyncStoreTest.java
- OffsetSyncTest.java
- OffsetSyncWriterTest.java
- TestUtils.java
- log4j2.yaml
- Checkpoint.java
- DefaultReplicationPolicy.java
- Heartbeat.java
- IdentityReplicationPolicy.java
- MirrorClient.java
- MirrorClientConfig.java
- package-info.java
- RemoteClusterUtils.java
- ReplicationPolicy.java
- SourceAndTarget.java
- MirrorClientTest.java
- MirrorRecordVersionTest.java
- ReplicationPolicyTest.java
- SourceAndTargetTest.java
- AbstractConnectCli.java
- ConnectDistributed.java
- ConnectStandalone.java
- AbstractConnectorClientConfigOverridePolicy.java
- AllConnectorClientConfigOverridePolicy.java
- AllowlistConnectorClientConfigOverridePolicy.java
- NoneConnectorClientConfigOverridePolicy.java
- PrincipalConnectorClientConfigOverridePolicy.java
- BooleanConverter.java
- BooleanConverterConfig.java
- ByteArrayConverter.java
- DoubleConverter.java
- FloatConverter.java
- IntegerConverter.java
- LongConverter.java
- NumberConverter.java
- NumberConverterConfig.java
- ShortConverter.java
- AbstractHerder.java
- AbstractStatus.java
- AbstractWorkerSourceTask.java
- CachedConnectors.java
- .asf.yaml
- .gitignore
- AGENTS.md
- build.gradle
- CONTRIBUTING.md
- HEADER
- LICENSE
- LICENSE-binary
- NOTICE
- NOTICE-binary
- README.md
- SECURITY.md
- Vagrantfile
# 설치 가이드
1. 코드 내려받기
git clone https://github.com/apache/kafka
깃허브에서 프로젝트 코드 전체를 내 컴퓨터로 내려받습니다.
cd kafka
방금 내려받은 프로젝트 폴더 안으로 이동합니다.
2. Gradle (Java/Kotlin)
보통 추천사전 준비물
- Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
- JDK (Java) Java/Kotlin 프로젝트를 빌드/실행하려면 필요합니다.
- Gradle 레포에 포함된 gradlew(Gradle Wrapper)를 쓰면 Gradle을 따로 설치할 필요가 없습니다.
./gradlew jar
Gradle로 빌드를 진행합니다.
./gradlew srcJar
Gradle로 빌드를 진행합니다.
./gradlew aggregatedJavadoc --no-parallel
Gradle로 빌드를 진행합니다.
./gradlew javadoc
Gradle로 빌드를 진행합니다.
./gradlew javadocJar # builds a javadoc jar for each module
Gradle로 빌드를 진행합니다.
BUILD SUCCESSFUL 메시지가 뜨면 성공입니다. build/ 폴더에 결과물이 생성됩니다.
이 레포의 README에 적힌 실제 명령어를 그대로 가져왔습니다.
3. Python
쉬움사전 준비물
pip install -r committer-tools/requirements.txt
requirements.txt 등에 명시된 파이썬 라이브러리를 설치합니다.
python <실행할 파일명>.py # README에서 정확한 실행 파일명을 확인하세요
파이썬 스크립트(또는 모듈)를 실행합니다.
에러 메시지 없이 실행되고 터미널에 안내 문구가 출력되면 정상입니다.
// repository documentation
Was this content helpful?
(0 ratings)
