对于顺序发送，我们需要知道，当数据写入一个partition时，可以保证顺序性，所以如果有一批数据需要保证顺序，那么给这批数据指定一个key即可。

来源：csdn.net/ldw201510803006/article/details/116176711消息监听容器1、KafkaMessageListenerContainer由spring提供用于监听以及拉取消息，并将这些消息按指定格式转换后交给由@KafkaListener注解的方法处理，相当于一...

谈到「Redis」你可能会想到用作缓存，然而「Redis」除了做缓存还有很多功能。比如做分布式锁，生成全局的「ID」，可以做延迟队列。除了这些「Redis」还可以做消息的发布订阅。...

◆ Stream源码解析Spring Cloud Stream（简称SCS）提供了一系列预先定义的注解来声明输入型和输出型Channel，业务系统基于这些Channel与消息中间件进行通信，而不是直接与具体的消息中间件进行通信。跟踪SCS的源码就会发现，St...

使用“kafka-topics.sh --zookeeper 127.0.0.1:2181 --list”指令再查看topic的时候，报“/d/kafka_2.10-0.10.2.0/bin/kafka-run-class.sh: line 259: D:Program: No such file or direct...

在高并发的时候，程序往往无法做到及时的处理。我们引入一个中间的系统，来进行分流和减压。

板块描述：板块分为概念板块、行业板块和地域板块，行情业务是按照行业划分的板块，比如：电子、房地产、银行等。每一个板块下又细分为很多的个股，所以板块实时行情能够反映行业下的个股行情概况。本节板块开发内容是针对沪市...

当前笔记中的内容针对的是 thinkphp-queue 的 v1.1.2 版本，现在官方已经更新到了 v1.1.3 版本， 下文中提到的几个Bug在最新的master分支上均已修复。笔记中的部分内容还未更新。...

如果是在idea里面执行，会使用本地环境，在命令行里面执行jar文件，会使用当前的执行环境

InLong（应龙）: 中国神话故事里的神兽，可以引流入海，借喻 InLong 系统提供数据接入能力。Apache InLong（应龙）是一个一站式的海量数据集成平台，提供自动、安全、可靠和高性能的数据传输能力，同时支持批和流，方便业务构建基于流...