kafka restful方式访问（docker下）

太过爱你忘了你带给我的痛 2022-06-01 06:45 411阅读 0赞

# kafka restful方式访问 #

本文主要介绍如何通过rest api的方式访问kafka。

主要参考：

https://cwiki.apache.org/confluence/display/KAFKA/Clients\#Clients-Proxy(HTTPREST,etc)

https://docs.confluent.io/current/kafka-rest/docs/api.html\#api-v2

https://docs.confluent.io/current/installation/docker/docs/quickstart.html

好，下面上货。

1、安装kafka-rest  proxy

docker run -d \
      --net=host \
      --name=kafka-rest-docker \
      -e KAFKA_REST_ZOOKEEPER_CONNECT=192.168.0.66:42181 \
      -e KAFKA_REST_LISTENERS=http://192.168.0.66:48082 \
      -e KAFKA_REST_HOST_NAME=192.168.0.66 \
      confluentinc/cp-kafka-rest:4.0.0

2、安装成功后可以查看端口48082是否正在监听（根据你启动时候的端口设置，我这里这是的是48082）。

netstat -apn |grep 48082

3、尝试查看kafka中的topics

http://192.168.0.66:48082/topics

返回结果：

\[test,test001\]

4、尝试向kafka中发送消息

http://192.168.0.66:48082/topics/test
    
    Accept:application/vnd.kafka.v2+json, application/vnd.kafka+json, application/json
    Content-Type:application/vnd.kafka.json.v2+json
    
    {
      "records": [
        {
          "value": {"sadfsdf":"dfdd"}
        }
      ]
    }

得到的返回响应

{
        "offsets": [
            {
                "partition": 0,
                "offset": 346,
                "error_code": null,
                "error": null
            }
        ],
        "key_schema_id": null,
        "value_schema_id": null
    }

这样就实现了通过rest api的方式向kafka中写入数据了。

在这里说一下，如果是消费的话，还是用正常的kafka c lient比较好。

发表评论取消回复

表情：

评论列表（有 0 条评论，411人围观）

还没有评论，来说两句吧...

相关阅读

相关 docker下删除kafka下topic

在公司的项目中需要用到kafka和c\进行消息发送，有一天不知道为啥，下端就出现一直读取消息的问题，所以得清空通道内的消息 1.docker ps 获取到当前kafka的容器

偏执的太偏执、/ 2023年01月24日 02:05/ 0 赞/ 379 阅读

相关 httpclient访问restful

转：http://howtodoinjava.com/2013/05/21/jax-rs-restful-client-using-apache-httpclient/

妖狐艹你老母/ 2022年09月29日 04:07/ 0 赞/ 162 阅读

相关 kafka rest api方式写入——java程序

kafka rest api方式写入——java程序本文主要介绍通过rest api方的方式写入kafka 本文前提是搭建一个kafka的proxy，然后启

我不是女神ヾ/ 2022年06月01日 06:52/ 0 赞/ 493 阅读

相关 kafka restful方式访问（docker下）

kafka restful方式访问本文主要介绍如何通过rest api的方式访问kafka。主要参考： https://cwiki.apache.org

太过爱你忘了你带给我的痛/ 2022年06月01日 06:45/ 0 赞/ 412 阅读

相关在Docker环境下部署Kafka

1、下载镜像这里使用了[wurstmeister/kafka][wurstmeister_kafka]和[wurstmeister/zookeeper][wurstme

冷不防/ 2022年04月15日 07:10/ 0 赞/ 392 阅读

相关 SharePoint—用REST方式访问列表

REST的定义与作用

你的名字/ 2022年04月03日 08:08/ 0 赞/ 205 阅读

相关 httpclient访问restful

转：http://howtodoinjava.com/2013/05/21/jax-rs-restful-client-using-apache-httpclient/

- 日理万妓/ 2022年03月10日 20:50/ 0 赞/ 235 阅读

相关 Docker 访问 Harbor私有仓库（二） -- 以 https 方式访问

1 说明 1. 前文[Centos7 搭建 Harbor 私有仓库(二) -- 修改为以https方式搭建][Centos7 _ Harbor _ -- _https]

港控/mmm°/ 2022年01月21日 04:39/ 0 赞/ 639 阅读

相关 Docker 访问 Harbor 私有仓库（一）-- 以http方式访问

1 说明 1. 前文[Centos7 搭建 Harbor 私有仓库(一) -- 以http方式搭建][Centos7 _ Harbor _ -- _http]我们成功搭

桃扇骨/ 2022年01月21日 04:35/ 0 赞/ 904 阅读

相关 docker容器下安装kafka实例

docker 环境的安装可以参考[《docker简介和linux下安装》][docker_linux] 镜像加速下载可以参考[《docker加速阿里云镜像地址，使用方式》]

傷城~/ 2021年09月29日 09:38/ 0 赞/ 335 阅读