# 特性(features) 1 订阅与发布 消息的发布是指某个生产者向某个topic发送消息；消息的订阅是指某个消费者关注了某个topic中带有某些tag的消息，进而从该topic消费数据。 2 消息顺序 消息有序指的是一类消息消费时，能按照发送的顺序来消费。例如：一个订单产生了三条消息分别是订单 ...
分类：
其他好文 时间：
2019-12-24 13:45:00
阅读次数：
95
最佳实践 1 生产者 1.1 发送消息注意事项 1 Tags的使用 一个应用尽可能用一个Topic，而消息子类型则可以用tags来标识。tags可以由应用自由设置，只有生产者在发送消息设置了tags，消费方在订阅消息时才可以利用tags通过broker做消息过滤：message.setTags("T ...
分类：
其他好文 时间：
2019-12-24 13:31:38
阅读次数：
76
交换机 交换机属性： Name：交换机名称 Type：交换机类型 direct、topic、fanout、headers Durability：是否需要持久化，true为持久化 Auto Delete：当最后一个绑定到Exchange上的队列删除后，自动删除该Exchange Internal：当前 ...
分类：
编程语言 时间：
2019-12-22 18:08:00
阅读次数：
79
图片来源网络 1.创建topic 2.启动三组go消费者 3.启动go生产者 4.第一组消费者输出 5.第二组消费者输出 6.第三组消费者输出 7.结论 1.消息将会被均匀的分布到不同的分区中 实现了负载均衡和水平扩展 2.消息会全量落到不同的消费者组 3.消费者组内的消费者共享一个消费者组ID 组 ...
分类：
其他好文 时间：
2019-12-22 16:16:32
阅读次数：
79
实现redis缓存装饰器，路由函数 func GetTopicDetail(context *gin.Context) { tid:=context.Param("topic_id") topics:=Topics{} DBHelper.Find(&topics,tid)//从数据库取 contex... ...
分类：
其他好文 时间：
2019-12-20 01:10:16
阅读次数：
111
api的url设计规则 router := gin.Default() router.GET("/topic/:topic_id", func(context *gin.Context) { context.String(http.StatusOK,"获取帖子Id为%s",context.Param... ...
package main import ( "github.com/gin-gonic/gin" "topic.jtthink.com/src" ) func main() { router := gin.Default() v1 := router.Group("/v1/topics") { v1... ...
分类：
其他好文 时间：
2019-12-20 00:56:24
阅读次数：
77
COMPSCI 671D Fall 2019Homework 41 EM Algorithm for Topic Modeling (35 points)In this question we will try to design an algorithm for discovering the a ...
分类：
其他好文 时间：
2019-12-19 13:06:15
阅读次数：
85
WARN - The configuration 'zookeeper.connect' was supplied but isn't a known config.WARN - The configuration 'input.topic' was supplied but isn't a kno ...
分类：
其他好文 时间：
2019-12-17 11:52:26
阅读次数：
2471
kafka要等一段时间才能消费到数据 pythonkafka 为什么用python写的kafka客户端脚本，程序一运行就能生产数据，而要等一段时间才能消费到数据（topic里面有数据）。（pykafka和confluentKafka都一样） 只有极少的概率立刻可以消费到数据，大多数都要等个几分钟，很 ...
分类：
其他好文 时间：
2019-12-16 22:14:04
阅读次数：
131
