添加用户adduser mosquitto 客户端订阅cd mosquitto-1.4/clientmosquitto_sub -t topic 启动 rabbit dockerdocker run -d -p 5672:5672 -p 1883:1883 -p 15672:15672 --name ...
分类:
其他好文 时间:
2019-07-16 12:17:30
阅读次数:
143
一、生产者配置 二、消费者配置 三、其它重要配置 ...
分类:
编程语言 时间:
2019-07-15 10:43:48
阅读次数:
277
sh kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test ...
分类:
其他好文 时间:
2019-07-14 19:35:40
阅读次数:
108
创建一个2个分区,3个副本的topic,名字叫first kafka-topics.sh --create --zookeeper datanode1:2181 --partitions 2 --replication-factor 3 --topic first 生产者发送消息顺序发送: 消费者接 ...
分类:
其他好文 时间:
2019-07-14 15:06:31
阅读次数:
274
[hadoop@datanode3 logs]$ kafka-topics.sh --delete --zookeeper datanode1:2181 --topic firstTopic first is marked for deletion.Note: This will have no i ...
分类:
Web程序 时间:
2019-07-13 22:44:50
阅读次数:
494
1.Kafka 的设计时什么样的呢? 1.Kafka 的设计时什么样的呢? Kafka 将消息以 topic 为单位进行归纳 将向 Kafka topic 发布消息的程序成为 producers. 将预订 topics 并消费消息的程序成为 consumer. Kafka 以集群的方式运行,可以由一 ...
分类:
其他好文 时间:
2019-07-13 21:28:42
阅读次数:
114
Greenplum数据库集群 系统版本:Red Hat Enterprise Linux (RHEL5) ...
分类:
数据库 时间:
2019-07-12 12:53:03
阅读次数:
116
1、RocketMQ结构 通过topic确定将消息发送到不同broker;broker中有多个messagequeue,消息放松到broker后经过轮询算法、hash算法等将消息发送到不同的messagequeue上 messagequeue本身不存放消息,真正的消息存放在commitlog中,me ...
分类:
其他好文 时间:
2019-07-11 15:47:20
阅读次数:
172
#查看topic频率rostopic hz /xxx_imu_driver/imu #查看topic信息rostopic info /xxx_imu_driver/imu #查看topic数据rostopic echo /xxx_imu_driver/imu ...
分类:
其他好文 时间:
2019-07-11 00:34:53
阅读次数:
225
创建 topic javatest bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic javatest --partitions 3 --replication-factor 1 java 连接:https: ...
分类:
编程语言 时间:
2019-07-08 19:29:05
阅读次数:
502