概念1、group：组内只有1个实例消费。如果不设置group，则stream会自动为每个实例创建匿名且独立的group——于是每个实例都会消费组内单次只有1个实例消费，并且会轮询负载均衡。通常，在将应用程序绑定到给定目标时，最好始终指定consumergroup2、destinationbinder：与外部消息系统通信的组件，为构造Binding提供了2个方法，分别是bindConsumer和b
分类：
编程语言 时间：
2019-08-11 23:36:54
阅读次数：
203
1113 Integer Set Partition (25 分) 1113 Integer Set Partition (25 分) 1113 Integer Set Partition (25 分) Given a set of N (>) positive integers, you are ...
分类：
其他好文 时间：
2019-08-11 12:49:05
阅读次数：
97
Given a linked list and a value x, partition it such that all nodes less than x come before nodes greater than or equal to x. You should preserve the ...
分类：
其他好文 时间：
2019-08-10 10:05:20
阅读次数：
77
problem:https://leetcode.com/problems/partition-equal-subset-sum/ 经典背包问题。找到是否存在恰好装满sum / 2的物体，可以优化为1D的。 ...
分类：
其他好文 时间：
2019-08-09 13:33:18
阅读次数：
66
原文: http://106.13.73.98/__/117/ __挖坑法思路：__ 取一个元素p（第一个元素），使元素p归位； 列表被p分成两部分，左边的数一定不大于p，右边的数一定不小于p； 递归完成排序。 __Python代码示例：__ python class QuickSort(objec ...
分类：
编程语言 时间：
2019-08-09 13:28:42
阅读次数：
92
一、Kafka介绍 kafka是消息中间件的一种，一个分布式、支持分区的（partition）、多副本的（replica），基于zookeeper协调的分布式消息系统，它的最大的特性就是可以实时的处理大量数据以满足各种需求场景：比如基于hadoop的批处理系统、低延迟的实时系统、storm/Spar ...
分类：
其他好文 时间：
2019-08-08 18:48:51
阅读次数：
112
sqlserver中有几种排序的方式 1、order by asc||desc 【默认值升序（asc）、降序：desc】 列：select * from tb order by id 2、ROW_NUMBER() over(partition by columnname order by colum ...
分类：
数据库 时间：
2019-08-07 22:50:57
阅读次数：
137
truncate t_target; insert into t_target （http://www.my516.com）select distinct t1.* from t_source t1, (select min(item_id) item_id,created_time,item_na ...
分类：
其他好文 时间：
2019-08-06 19:42:25
阅读次数：
109
fetch.min.bytes. #获取最小字节数据 Consumer 向broker中要数据时是按大小来返回的，如果数据没有达到指定的MB，consumer会处于等待状态，直到broker 从producer 哪里获取到指定大小的数据为止。获取取的最小数据大小是指的每个partition上的数据。... ...
分类：
其他好文 时间：
2019-08-06 00:41:49
阅读次数：
92
环境准备 zookeeper集群环境kafka是依赖于zookeeper注册中心的一款分布式消息对列，所以需要有zookeeper单机或者集群环境。 三台服务器： http://kafka.apache.org/downloads 中下载，目前最新版本的kafka已经到2.2.0,我这里之前下载的是 ...
分类：
系统相关 时间：
2019-08-03 15:09:43
阅读次数：
164
