发表于 | 分类于 |
Kafka所使用的基本术语 TopicKafka将消息种子(Feed)分门别类，每一类的消息称之为一个主题(Topic). Producer发布消息的对象称之为主题生产者(Kafka topic producer) Consumer订阅消息并处理发布的消息的种子的对象称之为主题消费者(consu ...
阅读全文 »

发表于 | 分类于 |
下载zookeeper 下载Kafka downloads 安装zookeeper单机服务 启动zookeeper 1~/software-dev/kafka_2.11-2.0.0/bin » ./zookeeper-server-start.sh ../config/zookeeper.prope ...
阅读全文 »

发表于 | 分类于 |
启动kafka服务1kafka_2.12-0.11.0.0/bin » ./kafka-server-start.sh -daemon ../config/server.properties topic 操作 创建topic 123# 创建了一个topic：test20181116，其分区数量：3 ...
阅读全文 »

发表于 | 分类于 |
线程池的实现原理类图" ThreadPoolExecutor: mainLock是独占锁，用来控制新增Worker线程操作的原子性。termination是该锁对应的条件队列。 Worker继承AQS并实现了Runnable接口，是具体承载任务的而对象。Worker继承了AQS，自己实现了简单不可重 ...
阅读全文 »