搜索结果
查询Tags标签： kafka，共有 918条记录-
OGG 实用案例（一）-oracle 同步kafka
01、源库安装ogg见OGG 安装 博客 02、源库配置oracle环境 环境说明：主机角色Ogg版本192.168.192.26源库191004_fbo_ggs_Linux_x64_shiphome.zip192.168.193.221目标库中间件KafkaOGG_BigData_Linux_x64_19.1.0.0.5.zip 01）、创建ogg同步用户SQL>create tablespac…
2021/8/4 19:08:29 人评论 次浏览 -
confluent-kafka demo
安装：confluent-kafka pip install confluent-kafka 我直接在PyCharm里面安装 启动zk, 启动kafka server 查看已有topic./kafka-topics.sh --zookeeper localhost:2181 --list创建topic testsh kafka-topics.sh --create --zookeeper localhost:2181 --replication-fact…
2021/8/4 6:06:48 人评论 次浏览 -
confluent-kafka demo
安装：confluent-kafka pip install confluent-kafka 我直接在PyCharm里面安装 启动zk, 启动kafka server 查看已有topic./kafka-topics.sh --zookeeper localhost:2181 --list创建topic testsh kafka-topics.sh --create --zookeeper localhost:2181 --replication-fact…
2021/8/4 6:06:48 人评论 次浏览 -
Docker快速创建Kafka环境
一、创建Kafka内部使用的bridge网络 docker network create kafka-net --driver bridge二、创建zookeeper docker run -d --name zookeeper-server \--network kafka-net \-e ALLOW_ANONYMOUS_LOGIN=yes \bitnami/zookeeper:latest三、创建Kafka服务 docker run -d --name…
2021/8/3 23:36:58 人评论 次浏览 -
Docker快速创建Kafka环境
一、创建Kafka内部使用的bridge网络 docker network create kafka-net --driver bridge二、创建zookeeper docker run -d --name zookeeper-server \--network kafka-net \-e ALLOW_ANONYMOUS_LOGIN=yes \bitnami/zookeeper:latest三、创建Kafka服务 docker run -d --name…
2021/8/3 23:36:58 人评论 次浏览 -
3.6 消息传递保障
1.传递保障 在一个分布式发布订阅消息系统中，组成系统的计算机总会由于各自的故障而不能正常工作。在Kafka中，一个单独的broker，可能会在生产者发送消息到一个topic的时候宕机，或出现网络故障，从而导致生产者发送消息失败。Kafka提供了三种传递保障来解决上述问题，其…
2021/8/3 23:06:34 人评论 次浏览 -
3.6 消息传递保障
1.传递保障 在一个分布式发布订阅消息系统中，组成系统的计算机总会由于各自的故障而不能正常工作。在Kafka中，一个单独的broker，可能会在生产者发送消息到一个topic的时候宕机，或出现网络故障，从而导致生产者发送消息失败。Kafka提供了三种传递保障来解决上述问题，其…
2021/8/3 23:06:34 人评论 次浏览 -
kafka shell简单使用
将kafka添加到环境变量中vim /etc/profile export KAFKA_HOME=/opt/iDataFusion/kafka export PATH=$PATH:$KAFKA_HOME/bin source /etc/profile 创建topic：--create： 指定创建topic动作 --topic：指定新建topic的名称 --zookeeper： 指定kafka连接zk的连接url，该值和…
2021/8/3 7:07:28 人评论 次浏览 -
kafka shell简单使用
将kafka添加到环境变量中vim /etc/profile export KAFKA_HOME=/opt/iDataFusion/kafka export PATH=$PATH:$KAFKA_HOME/bin source /etc/profile 创建topic：--create： 指定创建topic动作 --topic：指定新建topic的名称 --zookeeper： 指定kafka连接zk的连接url，该值和…
2021/8/3 7:07:28 人评论 次浏览 -
Spring Assistant框架搭建消息队列写入Kafka消费Windows单机测试
前提：已安装Java8、Maven 一、在Idea中创建Spring Assistant项目，选中web、Apache Kafka、lombok 二、导入Pom文件<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi=&q…
2021/8/2 7:08:45 人评论 次浏览 -
Spring Assistant框架搭建消息队列写入Kafka消费Windows单机测试
前提：已安装Java8、Maven 一、在Idea中创建Spring Assistant项目，选中web、Apache Kafka、lombok 二、导入Pom文件<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi=&q…
2021/8/2 7:08:45 人评论 次浏览 -
kafka教程
1.kafka 系统架构1.1 broker kafka 集群包含一个或多个服务器，服务器节点称为 broker。 1.2 Tpoic 每条发布到 kafka 集群的消息都有一个类别，这个类别称为 Topic。类似于数据的表名。物理上不同的 Topic 的消息分开存储。逻辑上一个 Topic 的消息虽然保存于一个或多个 …
2021/8/1 23:08:28 人评论 次浏览 -
kafka教程
1.kafka 系统架构1.1 broker kafka 集群包含一个或多个服务器，服务器节点称为 broker。 1.2 Tpoic 每条发布到 kafka 集群的消息都有一个类别，这个类别称为 Topic。类似于数据的表名。物理上不同的 Topic 的消息分开存储。逻辑上一个 Topic 的消息虽然保存于一个或多个 …
2021/8/1 23:08:28 人评论 次浏览 -
kafka 集群部署
部署环境： Server1:10.0.0.31 Server2:10.0.0.32 Server3:10.0.0.33 一、下载二进制kafka包 apt install -y apenjdk-8-jdkcd /usr/local/src wget https://mirrors.bfsu.edu.cn/apache/kafka/2.7.1/kafka_2.13-2.7.1.tgz tar xvf kafka_2.13-2.7.1.tgz ln -sv /usr/loca…
2021/7/31 23:08:44 人评论 次浏览 -
kafka 集群部署
部署环境： Server1:10.0.0.31 Server2:10.0.0.32 Server3:10.0.0.33 一、下载二进制kafka包 apt install -y apenjdk-8-jdkcd /usr/local/src wget https://mirrors.bfsu.edu.cn/apache/kafka/2.7.1/kafka_2.13-2.7.1.tgz tar xvf kafka_2.13-2.7.1.tgz ln -sv /usr/loca…
2021/7/31 23:08:44 人评论 次浏览
