GitHub - jaceklaskowski/kafka-notebook: The Internals of Apache Kafka

Name		Name	Last commit message	Last commit date
Latest commit History 550 Commits
graffles		graffles
images		images
LICENSE		LICENSE
README.adoc		README.adoc
SUMMARY.adoc		SUMMARY.adoc
book-intro.adoc		book-intro.adoc
book.json		book.json
kafka-Cluster-deprecated.adoc		kafka-Cluster-deprecated.adoc
kafka-ClusterConnectionStates.adoc		kafka-ClusterConnectionStates.adoc
kafka-ClusterResourceListener.adoc		kafka-ClusterResourceListener.adoc
kafka-InterBrokerSendThread.adoc		kafka-InterBrokerSendThread.adoc
kafka-Kafka.adoc		kafka-Kafka.adoc
kafka-KafkaHealthcheck.adoc		kafka-KafkaHealthcheck.adoc
kafka-KafkaMetricsReporter.adoc		kafka-KafkaMetricsReporter.adoc
kafka-KafkaScheduler.adoc		kafka-KafkaScheduler.adoc
kafka-KafkaServerStartable.adoc		kafka-KafkaServerStartable.adoc
kafka-Metrics.adoc		kafka-Metrics.adoc
kafka-MetricsReporter.adoc		kafka-MetricsReporter.adoc
kafka-OffsetConfig.adoc		kafka-OffsetConfig.adoc
kafka-ProducerMetrics.adoc		kafka-ProducerMetrics.adoc
kafka-Scheduler.adoc		kafka-Scheduler.adoc
kafka-Sensor.adoc		kafka-Sensor.adoc
kafka-ShutdownableThread.adoc		kafka-ShutdownableThread.adoc
kafka-TransactionCoordinator.adoc		kafka-TransactionCoordinator.adoc
kafka-TransactionMarkerChannelManager.adoc		kafka-TransactionMarkerChannelManager.adoc
kafka-TransactionStateManager.adoc		kafka-TransactionStateManager.adoc
kafka-ZKRebalancerListener.adoc		kafka-ZKRebalancerListener.adoc
kafka-ZkUtils.adoc		kafka-ZkUtils.adoc
kafka-ZooKeeperClient.adoc		kafka-ZooKeeperClient.adoc
kafka-admin-AclCommand-JAuthorizerService.adoc		kafka-admin-AclCommand-JAuthorizerService.adoc
kafka-admin-AclCommand.adoc		kafka-admin-AclCommand.adoc
kafka-admin-AclCommandService.adoc		kafka-admin-AclCommandService.adoc
kafka-admin-AdminClientService.adoc		kafka-admin-AdminClientService.adoc
kafka-admin-AdminUtils.adoc		kafka-admin-AdminUtils.adoc
kafka-admin-BrokerApiVersionsCommand.adoc		kafka-admin-BrokerApiVersionsCommand.adoc
kafka-admin-ConsumerGroupCommand.adoc		kafka-admin-ConsumerGroupCommand.adoc
kafka-admin-ConsumerGroupService.adoc		kafka-admin-ConsumerGroupService.adoc
kafka-admin-LeaderElectionCommand.adoc		kafka-admin-LeaderElectionCommand.adoc
kafka-admin-TopicCommand.adoc		kafka-admin-TopicCommand.adoc
kafka-brokers.adoc		kafka-brokers.adoc
kafka-clients-ClientRequest.adoc		kafka-clients-ClientRequest.adoc
kafka-clients-ClientResponse.adoc		kafka-clients-ClientResponse.adoc
kafka-clients-ClientUtils.adoc		kafka-clients-ClientUtils.adoc
kafka-clients-CommonClientConfigs.adoc		kafka-clients-CommonClientConfigs.adoc
kafka-clients-DefaultMetadataUpdater.adoc		kafka-clients-DefaultMetadataUpdater.adoc
kafka-clients-KafkaClient.adoc		kafka-clients-KafkaClient.adoc
kafka-clients-Metadata-Listener.adoc		kafka-clients-Metadata-Listener.adoc
kafka-clients-Metadata.adoc		kafka-clients-Metadata.adoc
kafka-clients-MetadataUpdater.adoc		kafka-clients-MetadataUpdater.adoc
kafka-clients-NetworkClient.adoc		kafka-clients-NetworkClient.adoc
kafka-clients-NetworkClientUtils.adoc		kafka-clients-NetworkClientUtils.adoc
kafka-clients-RequestCompletionHandler.adoc		kafka-clients-RequestCompletionHandler.adoc
kafka-clients-StaleMetadataException.adoc		kafka-clients-StaleMetadataException.adoc
kafka-clients-admin-Admin.adoc		kafka-clients-admin-Admin.adoc
kafka-clients-admin-AdminClient.adoc		kafka-clients-admin-AdminClient.adoc
kafka-clients-admin-KafkaAdminClient-AdminClientRunnable.adoc		kafka-clients-admin-KafkaAdminClient-AdminClientRunnable.adoc
kafka-clients-admin-internals-AdminMetadataManager.adoc		kafka-clients-admin-internals-AdminMetadataManager.adoc
kafka-clients.adoc		kafka-clients.adoc
kafka-cluster-Broker.adoc		kafka-cluster-Broker.adoc
kafka-cluster-EndPoint.adoc		kafka-cluster-EndPoint.adoc
kafka-cluster-Partition.adoc		kafka-cluster-Partition.adoc
kafka-cluster-PartitionStateStore.adoc		kafka-cluster-PartitionStateStore.adoc
kafka-cluster-Replica.adoc		kafka-cluster-Replica.adoc
kafka-cluster-ZkPartitionStateStore.adoc		kafka-cluster-ZkPartitionStateStore.adoc
kafka-clusters.adoc		kafka-clusters.adoc
kafka-common-Cluster.adoc		kafka-common-Cluster.adoc
kafka-common-Configurable.adoc		kafka-common-Configurable.adoc
kafka-common-NotificationHandler.adoc		kafka-common-NotificationHandler.adoc
kafka-common-Reconfigurable.adoc		kafka-common-Reconfigurable.adoc
kafka-common-TopicConfig.adoc		kafka-common-TopicConfig.adoc
kafka-common-ZkNodeChangeNotificationListener.adoc		kafka-common-ZkNodeChangeNotificationListener.adoc
kafka-common-config-SslConfigs.adoc		kafka-common-config-SslConfigs.adoc
kafka-common-config-internals-BrokerSecurityConfigs.adoc		kafka-common-config-internals-BrokerSecurityConfigs.adoc
kafka-common-network-Authenticator.adoc		kafka-common-network-Authenticator.adoc
kafka-common-network-ChannelBuilder.adoc		kafka-common-network-ChannelBuilder.adoc
kafka-common-network-ChannelBuilders.adoc		kafka-common-network-ChannelBuilders.adoc
kafka-common-network-KafkaChannel.adoc		kafka-common-network-KafkaChannel.adoc
kafka-common-network-SaslChannelBuilder.adoc		kafka-common-network-SaslChannelBuilder.adoc
kafka-common-network-Selectable.adoc		kafka-common-network-Selectable.adoc
kafka-common-network-Selector.adoc		kafka-common-network-Selector.adoc
kafka-common-network-SslChannelBuilder-SslAuthenticator.adoc		kafka-common-network-SslChannelBuilder-SslAuthenticator.adoc
kafka-common-network-SslChannelBuilder.adoc		kafka-common-network-SslChannelBuilder.adoc
kafka-common-record-AbstractRecords.adoc		kafka-common-record-AbstractRecords.adoc
kafka-common-record-BaseRecords.adoc		kafka-common-record-BaseRecords.adoc
kafka-common-record-FileRecords.adoc		kafka-common-record-FileRecords.adoc
kafka-common-record-MemoryRecords.adoc		kafka-common-record-MemoryRecords.adoc
kafka-common-record-MemoryRecordsBuilder.adoc		kafka-common-record-MemoryRecordsBuilder.adoc
kafka-common-record-Records.adoc		kafka-common-record-Records.adoc
kafka-common-requests-AbstractRequest-Builder.adoc		kafka-common-requests-AbstractRequest-Builder.adoc
kafka-common-requests-AbstractRequest.adoc		kafka-common-requests-AbstractRequest.adoc
kafka-common-requests-AbstractRequestResponse.adoc		kafka-common-requests-AbstractRequestResponse.adoc
kafka-common-requests-AbstractResponse.adoc		kafka-common-requests-AbstractResponse.adoc
kafka-common-requests-DescribeConfigsRequest.adoc		kafka-common-requests-DescribeConfigsRequest.adoc
kafka-common-requests-DescribeLogDirsRequest.adoc		kafka-common-requests-DescribeLogDirsRequest.adoc
kafka-common-requests-ElectPreferredLeadersRequest.adoc		kafka-common-requests-ElectPreferredLeadersRequest.adoc
kafka-common-requests-FetchRequest.adoc		kafka-common-requests-FetchRequest.adoc
kafka-common-requests-FindCoordinatorRequest.adoc		kafka-common-requests-FindCoordinatorRequest.adoc
kafka-common-requests-FindCoordinatorResponse.adoc		kafka-common-requests-FindCoordinatorResponse.adoc
kafka-common-requests-HeartbeatRequest.adoc		kafka-common-requests-HeartbeatRequest.adoc
kafka-common-requests-JoinGroupRequest.adoc		kafka-common-requests-JoinGroupRequest.adoc

Folders and files

Latest commit

History

Repository files navigation

About

Topics

Resources

License

Uh oh!

Stars

Watchers

Forks

Releases

Packages 0

Uh oh!

Contributors

Uh oh!

Packages