kafka
2016-12-26 21:28:34 0 举报
Kafka是一个分布式流处理平台,由LinkedIn开发并开源。它主要用于构建实时数据管道和流应用,具有高吞吐量、可扩展性和容错性等特点。Kafka基于发布-订阅模式,将消息存储在多个分区中,通过消费者组进行消费。这使得Kafka能够处理大量数据,同时保证数据的可靠性和实时性。Kafka广泛应用于日志收集、监控数据聚合、实时数据处理等场景,已成为大数据领域不可或缺的基础设施之一。
作者其他创作
大纲/内容
创建topicMetadataRequest
ClientUtils
SyncProducer
PartitionMetadata
根据config 创建 Producer
TopicMetadataResponse.readFrom(response.buffer)
doSent(request)根据broker list 网络获取 response
producer.send(topicMetadataRequest)
TopicMetadataResponse
buffer获取 partitionId、leaderId 、leaderPartitionMetadata
Producer
0 条评论
下一页