BigData/Kafka/Kafka之broker

Kafka启动过程

首先执行 ./bin/kafka-server-start.sh ./config/server.properties &
里面的最后一句 exec $base_dir/kafka-run-class.sh $EXTRA_ARGS kafka.Kafka “$@”执行kafka.Kafka类,从里面可以发现,它使用了KafkaServerStartable,里面封装有KafkaServer,最终startup执行的是KafkaServer,KafkaServer里面的参数说明

1
2


Kafka通信详情

Kafka初识

kafka的设计主要目标

  • 以复杂度O(1)的方式提供消息持久化能力,即使对TB级以上的数据也能保证常数的访问性能
  • 高吞吐率,即使在非常廉价的商用机器也能做到单机支持秒100k条消息的传输
  • 支持Kafka Server间消息分区,及分布式消费,同时保证分区内的消息顺序传输
  • 支持离线的数据处理和实时数据处理
  • 支持在线水平扩展
Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×