`
kane_xie
  • 浏览: 144975 次
社区版块
存档分类
最新评论

Kafka Rest : Confluent

阅读更多

最近拿到一个kafka rest的需求,但kafka暂时还没有提供rest api(应该是有在开发中,毕竟rest这么火),上网搜了一下,找到一个Confluent Platform,本文简单介绍一下安装。


这里插一句,给大家推荐一个九尾搜索,原名叫谷粉SOSO,不想fanqiang谷歌的可以用这个。以前在外企用谷歌用习惯了,出来之后用度娘搜技术问题,那匹配度简直感人。

  • 环境声明:Ubuntu 4.8.2, Java version "1.7.0_55",已经安装zookeeper和kafka
  • 安装Confluent Platform

官网提供了几种下载安装的方法,我是直接在本地下载然后拷贝到linux机器上

 

http://packages.confluent.io/archive/1.0/confluent-1.0-2.10.4.tar.gz

 
然后解压

 

tar xzf confluent-1.0-2.10.4.tar.gz
cd confluent-1.0

 

  • 编辑etc/kafka-rest/kafka-rest.properties, 修改zookeeper.connect为你的kafka集群的zookeeper地址
  • 启动kafka restserve : bin/kafka-rest-start
  • 测试 : curl "http://localhost:8082/topics"

 

7
1
分享到:
评论

相关推荐

    kafka-rest:用于Kafka的融合REST代理

    Kafka REST代理 Kafka REST代理为Kafka集群提供了RESTful接口。 无需使用本机Kafka协议或客户端,即可轻松生成和使用消息,查看集群状态以及执行管理操作。 用例示例包括使用任何语言构建的任何前端应用程序向Kafka...

    kafka_rest:Ruby宝石,用于与Confluent交谈kafka-rest

    的Kafka rest代理的Ruby客户端。用法安装将gem 'kafka_rest'行添加到应用程序的Gemfile ,然后运行bundle install 。贡献分叉( ) 创建功能分支( git checkout -b my-new-feature ) 提交更改( git commit -am '...

    cp-ansible:Confluent平台的Ansible剧本

    CP-Ansible 介绍 ...Kafka Connect(分布式模式) KSQL服务器 文献资料 您可以在找到运行CP-Ansible的文档。 您可以在找到受支持的配置变量 贡献 如果您想为CP-Ansible项目做出贡献,请参考 执照

    cp-helm-charts:Confluent Platform Helm图表使您能够在Kubernetes上部署Confluent Platform服务以进行开发,测试和概念验证环境

    通过这个项目,开发者和管理员可以快速地在Kubernetes集群上设置一套完整的Confluent Platform,包括Kafka、Zookeeper、Kafka Connect、Kafka REST Proxy以及KSQL Server,从而实现高效的数据流管理和处理。

    kafkaconnect:kafka连接示例

    4. 监控与管理:通过Kafka Connect REST API,可以监控连接器的状态,调整任务数量,或者更新配置。 **3. Java在Kafka Connect中的作用** Kafka Connect API是用Java编写的,因此开发者可以使用Java创建自定义连接...

    confluent kafka definitive guide complete

    Kafka还拥有REST Proxy,允许非Java客户端通过REST API与Kafka集群进行交互。这使得开发者可以使用多种编程语言来编写生产者和消费者,促进了Kafka在各种开发环境中的应用。 最后,Kafka的官方文档和指南,比如...

    confluent:合流图片库

    hkvb/confluent图片库 合流图像库。 控制中心 hkvb /汇合/控制中心 简单的Confluent Controlcenter堆栈... 用于Confluent Kafka Connect的REST客户端。 hkvb / confluent / kafka_connect / traefik 简单的汇合的Kafk

    schema-registry:适用于Kafka的Confluent Schema Registry

    它提供了插入到ApacheKafka:registered:客户端的序列化程序,这些客户端处理模式存储和以任何受支持的格式发送的Kafka消息的检索。 本自述文件包括以下部分:文献资料这是Confluent文档中指向Schema Registry页面的...

    代码:kafka数据接入到mysql中

    - 通过Kafka Connect REST API或Confluent Control Center(如果使用了Confluent Platform)来监控数据迁移过程,查看错误和警告,调整配置。 6. **数据一致性与幂等性** - 为了确保数据的一致性,可以设置Kafka ...

    ccloud-tools:从Confluent平台运行工具以及您的Confluent Cloud:trade_mark:集群

    这个工具包包括了对Kafka、Schema Registry、Kafka Connect、Control Center、REST Proxy等一系列Confluent Platform组件的管理功能。通过ccloud-tools,开发者可以轻松地创建、配置和管理云中的Kafka集群,进行数据...

    kafka-rest-utils:实用程序和用于与Jersey,Jackson和Jetty一起构建REST服务的小型框架

    融合的REST实用程序Confluent REST Utils提供了一个小型框架和实用程序,用于使用Jersey,Jackson,Jetty和Hibernate Validator编写Java REST API。 有关简单的演示服务,请参见目录。安全REST Application可以同时...

    kafka-aws-deployment:在 AWS 上部署 Kafka 的 Terraform 自动化。 这旨在帮助我和其他人尝试使用 Kafka

    kafka-aws-部署 该项目通过 terraform 将 Kafka 及其部分生态系统... Kafka Rest 代理 API(由Confluent通过) Kafka KSQL 服务器(由Confluent通过) 专有网络 RDS数据库 负载均衡器 先决条件 您需要以下内容来部

    kafka-connect-python:Kafka Connect REST API的Python模块

    Kafka Connect REST API的Python模块 要求 巨蟒(3.6) 安装 使用pip安装... pip install kafka-connect-python 例子 创建KafkaConnect REST接口 from kafka_connect import KafkaConnect connect = Kafka...

    Kafka_qwzhn-00.zip

    - **Confluent Platform**:一个全面的Kafka发行版,包括额外的工具和服务,如Schema Registry、Kafka Connect和Kafka REST Proxy。 以上只是Kafka知识体系的一部分,详细内容可以在《Kafka权威指南》中找到更深入...

    自用kafka文档,如果侵权请联系删除

    这是一家专注于Kafka的企业,提供了额外的工具和服务,如Confluent Open Source Connectors,支持多种客户端(包括Python、C/C++和.NET),Schema Registry用于管理数据模式的一致性,以及REST Proxy,使得与Kafka的...

Global site tag (gtag.js) - Google Analytics