#py2.7版本使用kafka，py3.7版本使用kafka-pythonimport datetimeimport jsonimport timefrom kafka import KafkaProducerproducer = KafkaProducer(bootstrap_servers='l ...
分类：
编程语言 时间：
2020-03-11 01:16:42
阅读次数：
192
1 import java.util.Random; 2 import javax.jms.Connection; 3 import javax.jms.ConnectionFactory; 4 import javax.jms.DeliveryMode; 5 import javax.jms.De ...
分类：
其他好文 时间：
2020-03-09 13:40:06
阅读次数：
72
引用：https://www.cnblogs.com/adolfmc/p/7345333.html 创建一个消息队列： bin/kafka-topics.sh --create --replication-factor 1 --partitions 1 --topic test --zookeepe ...
分类：
其他好文 时间：
2020-03-07 10:13:38
阅读次数：
73
1.redis消息模式 发布消息通常有两种模式分为：队列模式（queuing）和发布订阅模式（publish-subscribe）。 队列模式中，consumers可以同时从服务端读取消息，每个消息只被其中一个consumer读到。 发布订阅模式中消息被广播到所有的consumer中，topic中的 ...
分类：
其他好文 时间：
2020-03-06 01:19:35
阅读次数：
100
考虑到很多同学和我一样遵纪守法，都没有FQ，在访问Thingsboard官方在线演示时，会出现google机器人验证不了的问题。所以我们决定提供一个服务器来给大家试用，服务器配置不高，可能有点慢，见谅！另外，请大家不要修改密码，方便自己也方便大家。谢谢 地址： "点击这里查看：Thingsboard ...
分类：
其他好文 时间：
2020-03-05 23:39:55
阅读次数：
145
1.Kafka文件存储基本结构 1）在Kafka文件存储中，同一个topic下有多个不同partition，每个partition为一个目录，partiton命名规则为topic名称+有序序号，第一个partiton序号从0开始，序号最大值为partitions数量减1 2）每个partion(目录 ...
分类：
其他好文 时间：
2020-03-03 22:34:12
阅读次数：
102
什么是再平衡 所谓的再平衡，指的是在kafka consumer所订阅的topic发生变化时发生的一种分区重分配机制。一般有三种情况会触发再平衡： consumer group中的新增或删除某个consumer，导致其所消费的分区需要分配到组内其他的consumer上； consumer订阅的top ...
分类：
其他好文 时间：
2020-03-03 20:35:52
阅读次数：
86
《Concurrent包中的锁机制》http://www.iteye.com/topic/333669《java.util.concurrent 之ConcurrentHashMap 源码分析》http://www.iteye.com/topic/977348《ConcurrentHashMap之实... ...
分类：
其他好文 时间：
2020-03-03 14:54:42
阅读次数：
58
1. 概述 Kafka是一个分布式、支持分区的、多副本的，基于zookeeper协调的分布式消息系统。 2. Kafka的特性 （1）高吞吐量、低延迟：Kafka每秒可以处理几十万条消息，它的延迟最低只有几毫秒，每个主题topic可以分为多个分区partition，消费者组consumer grou ...
分类：
其他好文 时间：
2020-03-01 19:38:00
阅读次数：
72
1.话题【Topic】执行命令： 1 php artisan make:model Topic –cmr修改****_**_**_create_topics_table.php数据库迁移文件如下： 1 class CreateTopicsTable extends Migration 2 { 3 /... ...
分类：
Web程序 时间：
2020-02-28 14:07:18
阅读次数：
75
