搜索结果
查询Tags标签： kafka，共有 918条记录-
【架构师面试-消息队列-2】-消息队列使用场景剖析
1：应用解耦 1：原系统缺点是耦合性太强，每个系统都要接入A，每次加入新系统是不是都需要修改代码？ 2：应用解耦需要被接入的系统A只需要将消息写入MQ即可，每个需要对接系统A的系统只需要订阅消息队列的消息，系统A的代码完全不需要修改。 3：举例 用户支付订单完成后，…
2021/11/22 23:16:00 人评论 次浏览 -
【架构师面试-消息队列-2】-消息队列使用场景剖析
1：应用解耦 1：原系统缺点是耦合性太强，每个系统都要接入A，每次加入新系统是不是都需要修改代码？ 2：应用解耦需要被接入的系统A只需要将消息写入MQ即可，每个需要对接系统A的系统只需要订阅消息队列的消息，系统A的代码完全不需要修改。 3：举例 用户支付订单完成后，…
2021/11/22 23:16:00 人评论 次浏览 -
学生笔记linux、mysql
这篇文章不建议大家阅读，文章内容比较杂乱，只是我在学习过程中遇到问题，写下的笔记。linux：非常用命令 重启防火墙 systemctl restart firewalld.service查看网卡状态 systemctl status network.servicekafka打开topic：t100 生产消息/training/kafka_2.11-2.3.1/bin/…
2021/11/22 2:10:02 人评论 次浏览 -
学生笔记linux、mysql
这篇文章不建议大家阅读，文章内容比较杂乱，只是我在学习过程中遇到问题，写下的笔记。linux：非常用命令 重启防火墙 systemctl restart firewalld.service查看网卡状态 systemctl status network.servicekafka打开topic：t100 生产消息/training/kafka_2.11-2.3.1/bin/…
2021/11/22 2:10:02 人评论 次浏览 -
Kafka单机版安装教程及测试（附每一步操作截图及说明）【一看就懂】
衔接上文，若对kafka还不太了解的朋友请参考： 一文带你了解Kafka【一看就懂】_杨大仙-CSDN博客| 1.校验java环境及JDK是否已安装 java -version若还没有安装，请先安装配置java环境： Linux系统中Java环境的搭建及JDK的安装（附上每一步操作截图及说明）【一看就懂】_杨大…
2021/11/21 23:42:06 人评论 次浏览 -
Kafka单机版安装教程及测试（附每一步操作截图及说明）【一看就懂】
衔接上文，若对kafka还不太了解的朋友请参考： 一文带你了解Kafka【一看就懂】_杨大仙-CSDN博客| 1.校验java环境及JDK是否已安装 java -version若还没有安装，请先安装配置java环境： Linux系统中Java环境的搭建及JDK的安装（附上每一步操作截图及说明）【一看就懂】_杨大…
2021/11/21 23:42:06 人评论 次浏览 -
kafka、rabbitmq、redis区别，各自适合什么场景？
转载kafka、rabbitmq、redis区别，各自适合什么场景？ - Kris-Q - 博客园 在应用场景方面RabbitMQ RabbitMQ遵循AMQP协议，由内在高并发的erlanng语言开发，用在实时的对可靠性要求比较高的消息传递上，适合企业级的消息发送订阅，也是比较受到大家欢迎的。kafka kafka是L…
2021/11/21 2:12:07 人评论 次浏览 -
kafka、rabbitmq、redis区别，各自适合什么场景？
转载kafka、rabbitmq、redis区别，各自适合什么场景？ - Kris-Q - 博客园 在应用场景方面RabbitMQ RabbitMQ遵循AMQP协议，由内在高并发的erlanng语言开发，用在实时的对可靠性要求比较高的消息传递上，适合企业级的消息发送订阅，也是比较受到大家欢迎的。kafka kafka是L…
2021/11/21 2:12:07 人评论 次浏览 -
mongoDB CDC to Doris
MongoDB CDC to Doris 目标：mongodb --flink cdc--> kafka --> doris 一、环境准备 1. 版本ubuntu 20.04 mongodb 4.2 doris 0.14 flink 1.13.3 kafka 2.4.1 flink-sql-connector-mongodb-cdc-2.1.0.jar2. 把 mongodb-cdc和 kafka 的 connector 包放入flink lib 目…
2021/11/20 19:09:50 人评论 次浏览 -
mongoDB CDC to Doris
MongoDB CDC to Doris 目标：mongodb --flink cdc--> kafka --> doris 一、环境准备 1. 版本ubuntu 20.04 mongodb 4.2 doris 0.14 flink 1.13.3 kafka 2.4.1 flink-sql-connector-mongodb-cdc-2.1.0.jar2. 把 mongodb-cdc和 kafka 的 connector 包放入flink lib 目…
2021/11/20 19:09:50 人评论 次浏览 -
各组件命令
【02】Kafka主题的增、删、查增： bin/kafka-topics.sh --create --topic flink_kafka --partitions 3 --replication-factor 2 --bootstrap-server node1:9092,node2:9092,node3:9092删： bin/kafka-topics.sh --delete --topic bigdata01 --bootstrap-server node1:9092…
2021/11/19 6:40:03 人评论 次浏览 -
各组件命令
【02】Kafka主题的增、删、查增： bin/kafka-topics.sh --create --topic flink_kafka --partitions 3 --replication-factor 2 --bootstrap-server node1:9092,node2:9092,node3:9092删： bin/kafka-topics.sh --delete --topic bigdata01 --bootstrap-server node1:9092…
2021/11/19 6:40:03 人评论 次浏览 -
kafka创建主题时循环报错 java.net.ConnectException: 拒绝连接...【已解决】
今天犯了一个很低级的错误，导致循环报错：拒绝连接。报错信息如下： java.net.ConnectException: 拒绝连接at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)at org.apache.zooke…
2021/11/18 14:39:48 人评论 次浏览 -
kafka创建主题时循环报错 java.net.ConnectException: 拒绝连接...【已解决】
今天犯了一个很低级的错误，导致循环报错：拒绝连接。报错信息如下： java.net.ConnectException: 拒绝连接at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)at org.apache.zooke…
2021/11/18 14:39:48 人评论 次浏览 -
windows启动kafka_2.13-2.7.1
Kafka下载 下载地址 https://www.apache.org/dyn/closer.cgi?path=/kafka/2.7.1/kafka_2.13-2.7.1.tgz Kafka包名组成： Scala版本 - Kafka自身版本 下载界面 Kafka使用 1、启动zk 进入\bin\windows目录，执行命令 zookeeper-server-start.bat ..\..\config\zookeeper.pr…
2021/11/18 7:16:05 人评论 次浏览
