1.生产者命令: ./kafka-console-producer.sh --topic mytopic --broker-list node06:9092,node07:9092,node08:9092 2.消费者命令: ./kafka-console-consumer.sh --bootstra ...
分类:
其他好文 时间:
2019-06-29 00:26:50
阅读次数:
79
先从源码来深入理解一下 DirectKafkaInputDStream 的将 kafka 作为输入流时,如何确保 exactly-once 语义。 对应的源码如下: DirectKafkaInputDStream 的类声明如下: 简言之,Kafka RDD 的一个流,每一个指定的topic 的每一个 ...
分类:
其他好文 时间:
2019-06-26 00:39:53
阅读次数:
134
learning to link with wikipedia 目标:It explains how the topics mentioned in unstructured text can be automatically recognized and linked to the appropr ...
分类:
其他好文 时间:
2019-06-24 18:13:23
阅读次数:
132
师弟反应镭神32线激光雷达(32C)录制的数据包不能跑lego loam,这里就总结一下。 首先lego loam默认的接受的topic name是velodyne_points,点云的frame_id是velodyne,镭神驱动发布的topic name为point_raw,frame_id为wo ...
分类:
其他好文 时间:
2019-06-22 10:33:08
阅读次数:
304
使用rocketmq时报错 搜索原因,找到这几种解决方式 1: 在启动broker时,添加 autoCreateTopicEnable=true 如: mqbroker -n localhost:9876 autoCreateTopicEnable=true 2:检查lib下有无fastjson的j ...
分类:
其他好文 时间:
2019-06-20 23:49:25
阅读次数:
152
工作中因为各种原因, 例如topic中消息堆积的太多,或者kafka所在磁盘空间满了等等,可能需要彻底清理一下kafka topic,那么如何彻底删除topic?方法一(配置delete.topic.enable=true) 修改kafaka配置文件server.properties, 添加dele ...
分类:
其他好文 时间:
2019-06-20 17:21:30
阅读次数:
161
写介绍kafka的几个重要概念(可以参考之前的博文Kafka的简单介绍):Broker:消息中间件处理结点,一个Kafka节点就是一个broker,多个broker可以组成一个Kafka集群;Topic:一类消息,例如pageview日志、click日志等都可以以topic的形式存在,Kafka集群能够同时负责多个topic的分发;Partition:topic物理上的分组,一个topic可以分为
分类:
其他好文 时间:
2019-06-19 18:40:36
阅读次数:
206
Cesium 是一款面向三维地球和地图的,世界级的JavaScript开源产品。它提供了基于JavaScript语言的开发包,方便用户快速搭建一款零插件的虚拟地球Web应用,并在性能,精度,渲染质量以及多平台,易用性上都有高质量的保证。关于等高线,等高线指的是地形图上高程相等的相邻各点所连成的闭合曲... ...
分类:
其他好文 时间:
2019-06-18 09:18:13
阅读次数:
471
上面已提到消费端感知topic服务器有新消息叫推拉模式 左图采用短连接,server端不能获取clinet连接资源,无法主动推给client。所以要求client定时过来拿数据 右图采用长连接,server端可以获取clinet连接资源,有消息过来就能主动推给client 短连接应用受环境因素限制, ...
分类:
其他好文 时间:
2019-06-16 14:05:23
阅读次数:
145