最近在学习Kafka，准备测试集群状态的时候感觉无论是开三台虚拟机或者在一台虚拟机开辟三个不同的端口号都太麻烦了（嗯。。主要是懒）。
环境准备
一台可以上网且有CentOS7虚拟机的电脑
为什么使用虚拟机？因为使用的笔记本，所以每次连接网络IP都会改变，还要总是修改配置文件的，过于繁琐，不方便测试。（通过Docker虚拟网络的方式可以避免此问题，当时实验的时候没有了解到）
Docker 安装
如果已经安装Docker请忽略此步骤
Docker支持以下的CentOS版本：
CentOS 7 (64-bit)：要求系统为64位、系统内核版本为 3.10 以上。
CentOS 6.5（6
2021-12-15 23:06:24
592KB
1
Eventeum
以太坊事件监听器，将您的智能合约事件和后端微服务联系起来。 Eventeum侦听以太坊网络发出的特定事件，并将这些事件广播到您的中间件层。 这提供了不同的关注点分离，这意味着您的微服务不必直接将事件订阅到以太坊节点。
主
发展历程
产品特点
动态可配置-Eventeum公开了REST api，因此可以动态订阅/取消订阅智能合约事件。
高度可用-Eventeum实例彼此通信，以确保每个实例都订阅了相同的智能合约事件集合。
弹性-检测到节点故障，一旦节点重新联机，事件订阅将从故障块继续。
叉子容忍度-Eventeum可以配置为等待一定数量的块，然后再将事件视为“已确认
2021-12-14 16:13:07
387KB
1
kafak ksql 函数， 基于Confluent的ksqlDB各个函数的用法使用，本文档对官方英文文档进行了汉化和补充，翻译并测试。
2021-12-14 11:06:50
445KB
1
主要介绍了spring-cloud-stream结合kafka使用详解,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-12-13 16:40:56
40KB
1
网络爬虫
该存储库包含Otus Data Engineer课程的最终工作的源代码。 该项目是专注于Web的爬网程序，可递归地爬网网站。 它包含3个部分：
提取程序是一个nodejs应用程序。 它从frontier RMQ队列中读取URL，在选定的浏览器中打开页面，并将其内容存储在htmls kafka主题（HTML）和screenshots minio bucket（PNG）中。
提取程序是flink作业。 它从htmls kafka主题中读取HTML文档，提取内部链接并将其推入frontier RMQ队列。 该服务还实现了使用MapState消除重复URL（DUE）的逻辑。
运行程序是运行爬网的python脚本。
如何启动搜寻
docker-compose build ;
docker-compose up -d （等待〜20秒）;
docker-compose run -v
2021-12-13 09:42:25
50KB
1
storm链接kafka时需要导入kafka、storm和storm链接kafka的jar包外，还需要这些jar包的支持
2021-12-11 22:03:48
2.47MB
1