Spring Boot 自定义kafka 消费者配置 ContainerFactory最佳实践 本篇博文主要提供一个在 SpringBoot 中自定义 kafka配置的实践,想象这样一个场景:你的系统需要监听多个不同集群的消息,在不同的集群中topic冲突了,所以你需要分别定义kafka消息配置。 ...
分类:
编程语言 时间:
2020-04-26 20:53:05
阅读次数:
122
介绍完Topic之后,来讲一下opensplice数据的读/写。在Opensplice Overview中我们讲解了数据的读写,但为了能够充分利用DDS,有必要理解读/写操作和Topic instance生命周期之间的关系。 可以这里需要说明一下,我们可以通过理解面向对象的类/对象,来理解Topic ...
分类:
其他好文 时间:
2020-04-25 13:09:57
阅读次数:
67
在Overview中,简单介绍了一下Topic,下面详细介绍一下Topic。有不对的地方希望大家可以在留言区告诉我。 Topic是由名称(name)、类型(type)以及服务(QoS)组成。 1. Topic详解 (1)Topic Types Opensplice支持不同语法的topic,比如:ID ...
分类:
其他好文 时间:
2020-04-25 12:54:15
阅读次数:
72
阿里云安全月专题页链接:https://developer.aliyun.com/topic/securityapril全球连接,立体防护网络安全的最大挑战之一来自于不同地域的网络之间的访问,连接不同地域的阿里云网络产品,云企业网(CloudEnterpriseNetwork)是承载在阿里云提供的高性能、低延迟的私有全球网络上的一张安全网络。云企业网可在不同地域VPC间,VPC与本地数据中心间搭建
分类:
其他好文 时间:
2020-04-25 10:32:09
阅读次数:
106
生产者分区原则 1.指定partition编号的情况下,直接将指明的值直接作为partition值 2.没有指明partition值但有key的情况下,将key的hash值与topic的partition数进行取余得到partition值 3.没有partition值也没有key值的情况下,第一次调 ...
分类:
其他好文 时间:
2020-04-24 01:22:31
阅读次数:
72
一、Flutter 扫描二维码条形码插件 barcode_scan 1、安装 2、配置权限 Add the camera permission to your AndroidManifest.xml Add the BarcodeScanner activity to your AndroidMan ...
一、KafkaSink 1、按流内容分发到对应topic,隔天自动切换 在flink自带的kafka sink实现里,只支持写到固定topic,而我们的kafka2kafka日志处理逻辑要求消息要按照ds字段值写入到对应topic,topic名前缀相同,后面跟ds字段值,需要进行改造 具体实现思路如 ...
分类:
其他好文 时间:
2020-04-22 19:44:07
阅读次数:
183
Topic 模式 重点是理解交换器(exchange)、路由键(routing key)、队列名(queue name)三者之间的绑定关系。 topic 发送方: 发送方 关注参数主要有三个 交换器(exchange) 路由键(routing key) 和 消息 topic 消费方 消费方 关注点是 ...
分类:
编程语言 时间:
2020-04-22 00:13:18
阅读次数:
64
MQTT简介 mqtt基于订阅者模型架构,客户端如果互相通信,必须在同一订阅主题下,即都订阅了同一个topic,客户端之间是没办法直接通讯的。订阅模型显而易见的好处是群发消息的话只需要发布到topic,所有订阅了这个topic的客户端就可以接收到消息了。 发送消息必须发送到某个topic,重点说明的 ...
分类:
其他好文 时间:
2020-04-21 11:26:24
阅读次数:
96
1、讲解redis是为了什么? topic:高并发、亿级流量、高性能、海量数据的场景,电商网站的商品详情页系统的缓存架构 商品详情页系统,大型电商网站,会有很多部分组成,但是支撑高并发、亿级流量的,主要就是其中的大型的缓存架构 在这个大型的缓存架构中,redis是最最基础的一层 高并发,缓存架构中除 ...
分类:
其他好文 时间:
2020-04-21 09:46:24
阅读次数:
54