在消息RabbitMQ时,我们关心的一个问题是手动ack还是自动ack,如果是自动ack就怕出现丢消息的情况 Flink以RabbitMQ作为Source,是怎么保证消息唯一性的呢,是怎么保证ack的. 首先引入依赖包 <dependency> <groupId>org.apache.flink</ ...
分类:
其他好文 时间:
2021-06-11 19:15:45
阅读次数:
0
LINUX 系统的一些入门基础 Shell Linux系统中运行的一种特殊程序 在用户和内核之间充当“翻译官” 用户登录Linux系统时自动加载一个shell程序 Bash是Linux系统中默认使用的shell程序 文件位于/bin/bash Linux命令的分类 内部命令与外部命令的区别 内部命令 ...
分类:
系统相关 时间:
2021-06-11 18:52:59
阅读次数:
0
1.org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, MyTopic 报错信信息如下: Exception in thread "main" org.apache.rocketmq ...
分类:
其他好文 时间:
2021-06-11 18:46:49
阅读次数:
0
本文所指之数据工程,限定于: 数据分析、数据采集(集成) 1 网站 spider-flow - 智能高效的在线爬虫 spider-flow 是一个无需写代码的爬虫平台,以图形化方式定义爬虫流程,无需代码即可实现一个爬虫 superset.workerindata.com - 账号: bilibili ...
分类:
数据库 时间:
2021-06-11 18:27:40
阅读次数:
0
ke01开启: nc -lk 8888 Map package com.text.transformation import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment import org.apache.flink ...
分类:
其他好文 时间:
2021-06-11 18:25:57
阅读次数:
0
title: ActiveMQWithCpp author: Youdias date: 2021-06-10 15:29:26 tags: ActiveMQ C++ VS2019 win32 ActiveMQ简介 Apache下的一个子项目,一个消息中间件,支持点对点和订阅发布模式,支持多种语言客 ...
分类:
编程语言 时间:
2021-06-11 18:19:46
阅读次数:
0
Sampler-http请求之KeepAlive使用总结 测试环境 apache-jmeter-2.13 KeepAlive使用介绍 说明: 1、Use KeepAlive 勾上,则表示为求连接设置请求头Connection: keep-alive,该配置对默认的HTTP实现不起作用,因为连接重用不 ...
分类:
Web程序 时间:
2021-06-11 18:19:02
阅读次数:
0
前言 Apache Kafka的受欢迎程度很高,Kafka拥有充足的就业机会和职业前景。此外,在这个时代拥有kafka知识是一条快速增长的道路 而且无论是作为面试官,还是应聘者,我都接触过很多Kafka面试题。而在最近面试了很多候选人,发现写了熟悉Kafka,但是对于Kafka相关的知识却是只知道大 ...
分类:
编程语言 时间:
2021-06-11 18:11:03
阅读次数:
0
宝塔是一款Linux可视化软件 1.一键安装 apt-get install wget && wget -O install.sh http://download.bt.cn/install/install_6.0.sh && bash install.sh 2.卸载 1)打开shell终端,输入命 ...
分类:
系统相关 时间:
2021-06-11 18:10:52
阅读次数:
0
一个新的需求,需要在shell脚本中退出当前登录用户 方式一 #!/bin/bash I=$(tty |awk -F '/dev/' '{print $2}') pkill -kill -t $I 方式二 #!/bin/bash I=$(who am i|awk '{print $2}') pkil ...
分类:
系统相关 时间:
2021-06-11 17:45:51
阅读次数:
0