使用Docker(k8s)安装Kafka并使用宿主机连接

使用Docker(k8s)安装Kafka并使用宿主机连接使用Docker(k8s)安装Kafka并使用宿主机连接安装Docker及docker-compose具体安装方法可以去官网看教程检查docker-compose是否安装成功创建docker-compose.yml文件version:’2’services:zookeeper:image:”zookeeper”hostname:”zookeeper.local”container_name:”zookeeper”#设置网络别名可随

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

使用Docker(k8s)安装Kafka并使用宿主机连接

  1. 安装Docker及docker-compose
    具体安装方法可以去官网看教程
    检查docker-compose是否安装成功
    在这里插入图片描述
  2. 创建 docker-compose.yml 文件
version: '2'
services:
  zookeeper:
    image: "zookeeper"
    hostname: "zookeeper.local"
    container_name: "zookeeper"
    #设置网络别名 可随意取
    networks:
      local:
        aliases:
          - "zookeeper.local"
  kafka:
    image: "wurstmeister/kafka"
    hostname: "kafka.local"
    container_name: "kafka"
    ports:
      - "9092:9092"
    networks:
      local:
        aliases:
          - "kafka.local"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: kafka.local
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
#设置网络,名为local模式
networks:
  local:
    driver: bridge
  1. 进入Kafka容器
docker exec -it kafka /bin/bash
  1. 创建Topic
/opt/kafka_2.13-2.7.0/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 -replication-factor 1 --partitions 1 --topic test_topic
  1. 测试命令行生产消费
  • 生产者
/opt/kafka_2.13-2.7.0/bin/kafka-console-producer.sh --broker-list kafka.local:9092 --topic test_topic

在这里插入图片描述

  • 消费者
/opt/kafka_2.13-2.7.0/bin/kafka-console-consumer.sh --bootstrap-server kafka.local:9092 --topic test_top
ic --from-beginning

在这里插入图片描述

  1. 从宿主机使用代码连接Kafka
    6.1 进入Zookeeper容器查看brokers注册信息
    # 进入容器
    docker exec -it zookeeper /bin/bash
    
    # 进入zookeeper命令行
    bin/zkCli.sh
    

    6.2 查看brokers注册信息

    get /brokers/ids/1001
    

    在这里插入图片描述
    6.3 配置宿主机hosts

    # 添加
    127.0.0.1	kafka.local
    

    6.4 使用Java代码连接Kafka

    public class KafkaConsumerDemo { 
         
    public static void main(String[] args) { 
         
    	//1.配置消费者连接属性
    	Properties props = new Properties();
    	props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka.local:9092");
    	props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");
    	props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");
    	props.put(ConsumerConfig.GROUP_ID_CONFIG, "test_demo");
    
    
    	//2.创建Kafka消费者
    	KafkaConsumer<String, String> consumer = new KafkaConsumer<String, String>(props);
    
    	//3.订阅topics
    	consumer.subscribe(Arrays.asList("test_topic"));
    // consumer.assign(Arrays.asList(new TopicPartition("test_topic", 0)));
    // consumer.seekToBeginning(Arrays.asList(new TopicPartition("test_topic", 0)));//不改变当前offset
    
    	//4.死循环读取消息
    	for (; ; ) { 
         
    		ConsumerRecords<String, String> records = consumer.poll(Duration.ofSeconds(1));
    
    		if (records != null && !records.isEmpty()) { 
         
    			records.forEach(r -> { 
         
    				System.out.println("key:" + r.key() + "----value:" + r.value());
    			});
    		}
    	}
      }
    }
    

测试成功
在这里插入图片描述

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/171579.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • docker如何卸载_docker 删除容器

    docker如何卸载_docker 删除容器2.卸载docker相关包输入如下命令查看相关包把匹配到的包执行yumremove删除3.查看docker卸载成功

  • Docker部署_docker部署网站

    Docker部署_docker部署网站前言我们都爱用WordPress,(几乎)一行代码都不用写,就能得到一个好看、实用的动态网站。这东西用来敷衍帮助各种找你写奇怪小网站的朋友再好不过了。通常,帮朋友部署WordPress的这个场景下,你可以找朋友开一台新的服务器,初始化一套LAMP,直接把WordPress给wget进去,就可以在你的浏览器里完成配置了。有时候,比如您的朋友使用阿里云、百度云或是其他比较大的云服务商,您甚至可以直接初始化一个WordPress应用镜像,直接在浏览器里开始设置。但是,前两天我需要

    2022年10月26日
  • docker导入镜像命令_docker怎么删除镜像

    docker导入镜像命令_docker怎么删除镜像由于工作需要,要一次性导出机器上全部的镜像。

  • 普罗米修斯监控系统搭建(MAC环境基于Docker)「建议收藏」

    普罗米修斯监控系统搭建(MAC环境基于Docker)「建议收藏」采用Docker环境搭建方式可以快速搭建起测试学习环境第一步:下载docker镜像dockerpullprom/node-exporterdockerpullprom/prometheusdockerpullgrafana/grafana第二步:启动exporter(理解为内置好的监控埋点)dockerrun-d-p9100:9100\-v”/proc:/host/proc:ro”\-v”/sys:/host/sys:ro”\-v”/:/roo

  • 解决docker下载镜像速度过慢_docker image是什么

    解决docker下载镜像速度过慢_docker image是什么前言上一篇讲到pull镜像,但是pull镜像的时候下拉的速度实在感人,有什么解决办法吗?我们只需将docker镜像源修改为国内的将docker镜像源修改为国内的:在/etc/docker/d

  • docker mysql日志查看_MySQL查看版本

    docker mysql日志查看_MySQL查看版本查询DockerMySQL的版本号1.查找到当前正在运行的容器#dockerps2.进入mysql容器(命令中不带小括号)#dockerexec-it(mysql的名字,或id)bash3.登录mysql,输入账号密码登录(命令中不带小括号)#mysql-u(root)-p(abcd)登录成功以后,会显示该mysql的详细信息,其中包含版本号…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号