查看消费组详情: ./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-consumer-group 查看topic详情： ./bin/kafka-topics.sh --to ...
分类：
其他好文 时间：
2020-07-31 18:03:33
阅读次数：
83
队列：先进先出 头文件：<queue> 基本操作： queue<Type>q; //定义队列，Type可以系统定义的数据类型，也可以是自己定义的结构体类型 q.push(item); //把item放入队列的尾部 q.front(); //返回队首元素，但不会删除 q.pop(); //删除队首元素 ...
分类：
其他好文 时间：
2020-07-31 12:28:58
阅读次数：
87
#1.1 kafka启动命令nohup bin/kafka-server-start.sh config/server.properties & #1.2 kafka停止命令bin/kafka-server-stop.sh #1.3. kafka重启systemctl restart kafka # ...
分类：
其他好文 时间：
2020-07-30 14:45:42
阅读次数：
79
导航 (返回顶部) 1. 日志的查询1: 通常的时间+grep过滤. 2. 日志的查询2: field filter 字段过滤. 2.1 -F, -N命令 2.2 man systemd.journal-fields 2.3 本机可用字段及数据 1. 日志的查询1: 通常的时间+grep过滤. 2. ...
分类：
其他好文 时间：
2020-07-29 17:43:00
阅读次数：
104
https://zhuanlan.zhihu.com/p/159017211 看着这算法凌乱的很，太复杂了！说实话，确实挺复杂，蛮罗嗦的，但是代数法可以得到如下表格： 假设4个queueConsumer有2个可以整除Consumer有3个不可整除Consumer有5个无法都分配queue[0]Con ...
分类：
其他好文 时间：
2020-07-29 10:19:02
阅读次数：
69
###思路 这个题一看和入度扯上关系就是明显的topo了。 对于最优情况，直接维护小根堆，贪心即可。 对于最劣情况，显然直接维护大根堆然后贪心是错误的（反例见Luogu题解），所以每次要取出所有能拓展的节点，依次加入队列topo即可。这里注意当连到的点比当前最大值大时，压入大根堆， 否则加入队列。 ...
分类：
其他好文 时间：
2020-07-28 10:09:43
阅读次数：
65
package com.jeesite.modules.jiQiao.web;import java.util.function.Consumer;public class DemoConsumerTest01 { public static void main(String[] args) { / ...
分类：
编程语言 时间：
2020-07-26 19:40:41
阅读次数：
85
RabbitMq保证消息可靠性之确认模式 前提 完成 SpringBoot 整合 RabbitMq 中的Topic通配符模式 一、更改Producer工程的application.yml文件 spring: rabbitmq: host: localhost port: 5672 virtual-h ...
分类：
其他好文 时间：
2020-07-26 01:04:06
阅读次数：
114
一、Dijkstra和spfa 以下示例均使用邻接表。 Dijkstra： void Dijkstra(int S) { priority_queue <pii> Q; while(!Q.empty()) Q.pop(); memset(dis, 0x7f, sizeof(dis); memset( ...
分类：
其他好文 时间：
2020-07-24 21:22:49
阅读次数：
84
一、总体介绍 使用一个 Dept 部门模块做一个微服务通用案例 Consumer消费者（Client）通过 REST 调用 Provider 提供者（Server）提供的服务。 一个父工程中创建多个 Module 子模块：MicroServiceCloud父工程（Project）下初次带着三个子模块 ...
分类：
编程语言 时间：
2020-07-24 21:11:42
阅读次数：
72
