一： kafka文件组成 基本组成： 1- broker 节点，多个broker构成一个集群 2- topic 对消息进行归类 3- producer 生产者 4- comsumer 消费者 5- consumerGroup 消费组 topic的组成： 1- partition 物理上数据存储的概念 ...
分类：
其他好文 时间：
2019-05-14 19:31:44
阅读次数：
231
问题-：mysql如何进行以,分割的字符串的拆分分割开逗号分号的字段。其他字段自动补齐。https://blog.csdn.net/u012009613/article/details/52770567SELECTs.*from(SELECTt.ID,t.time_old,substring_index(substring_index(t.all_content,‘；‘,b.help_topic_
分类：
数据库 时间：
2019-05-13 17:55:39
阅读次数：
590
KafkaProducer在发送消息时必须配置的参数为：bootstrap.servers、key.serializer、value.serializer。序列化操作是在拦截器（Interceptor）执行之后并且在分配分区(partitions)之前执行的。首先我们通过一段示例代码来看下普通情况下KafkaProducer如何编写：publicclassProducerJavaDemo{publ
分类：
其他好文 时间：
2019-05-12 22:31:42
阅读次数：
165
精简极致的均线策略 30行打造一个正向收益系统 原帖地址：https://www.fmz.com/bbs-topic-new/262 没错！你听的没错是30行代码！仅仅30行小编我习惯先通篇来看看 代码，这样能有个宏观的了解！ 策略参数如下 导入了 交易类库 方便策略编写， 不用为 是否买到 是否卖 ...
分类：
编程语言 时间：
2019-05-10 12:55:45
阅读次数：
206
1、查看、修改真机端的页面DOM结构及样式【参考——https://imweb.io/topic/5981a34bf8b6c96352a59401】； 1.0、需要配置的rule——域名 weinre://随便某个分类命名【如：wq.jd.com weinre://test2——test2只是作为w ...
分类：
移动开发 时间：
2019-05-09 10:48:22
阅读次数：
197
原文:RabbitMQ指南之四：路由（Routing）和直连交换机（Direct Exchange） 在上一章中，我们构建了一个简单的日志系统，我们可以把消息广播给很多的消费者。在本章中我们将增加一个特性：我们可以订阅这些信息中的一些信息。例如，我们希望只将error级别的错误存储到硬盘中，同时可以... ...
分类：
其他好文 时间：
2019-05-04 16:19:45
阅读次数：
196
原文:RabbitMQ指南之五：主题交换器（Topic Exchange） 在上一章中，我们完善了我们的日志系统，用direct交换器替换了fanout交换器，使得我们可以有选择性地接收消息。尽管如此，仍然还有限制：不能基于多个标准进行路由。在我们的日志系统中，我们可能不仅希望根据日志等级订阅日志，... ...
分类：
其他好文 时间：
2019-05-04 16:12:40
阅读次数：
138
两张图读懂kafka应用： Kafka 中的术语 broker：中间的kafka cluster，存储消息，是由多个server组成的集群。 topic：kafka给消息提供的分类方式。broker用来存储不同topic的消息数据。 producer：往broker中某个topic里面生产数据。 c ...
分类：
其他好文 时间：
2019-05-04 11:50:24
阅读次数：
118
掌握talker写法，就可以驾驭周期性发布的场合了 其中pub = ...("...",1);//里面的的1意思是队列长度 如果 distance用的是c++的float就不用下面写distance.data了，直接用distance （疑问，） ...
分类：
其他好文 时间：
2019-05-04 10:13:44
阅读次数：
173
接下来只需要在cmakelist里定义msg就行了，而python文件不需要加入cmakelist，因为是解释型语言 ...
分类：
其他好文 时间：
2019-05-04 09:53:10
阅读次数：
107
