`

kafka接口协议

阅读更多

The Kafka protocol is fairly simple, there are only six client requests APIs.

 

  1. Metadata - Describes the currently available brokers, their host and port information, and gives information about which broker hosts which partitions.获得活着的broker,他们的host和port,broker包含的partition
  2. Send - Send messages to a broker  发送消息到broker
  3. Fetch - Fetch messages from a broker, one which fetches data, one which gets cluster metadata, and one which gets offset information about a topic.  从broker上获得消息,集群元数据和topic的offset
  4. Offsets - Get information about the available offsets for a given topic partition.获得topic的partition的offset
  5. Offset Commit - Commit a set of offsets for a consumer group 写入consumer group消费的offset
  6. Offset Fetch - Fetch a set of offsets for a consumer group 读取consumer group消费的offset
分享到:
评论

相关推荐

    Java API方式调用Kafka各种协议的方法

    本篇文章主要介绍了Java API方式调用Kafka各种协议的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

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

    Kafka REST代理为Kafka集群提供了RESTful接口。 它使生成和使用消息,查看群集状态以及执行管理操作变得很容易,而无需使用本机Kafka协议或客户端。 用例示例包括从使用任何语言构建的任何前端应用向Kafka报告数据,...

    kafka-rest, Kafka的合并REST代理.zip

    kafka-rest, Kafka的合并REST代理 Kafka REST代理REST REST代理为集群提供了REST式接口。 它使得生成和使用消息。查看集群状态以及在不使用本机 Kafka 协议或者客户端的情况下执行管理操作变得很容易。 用例示例包括...

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

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

    graphql-kafka-subscriptions:通过Kafka协议的Apollo graphql订阅

    它通过graphql-subscriptions包实现了PubSubEngine接口,并且还实现了新的AsyncIterator接口。 它使您可以将订阅管理器连接到用作发布/订阅通信渠道的单个Kafka主题。 安装 npm install graphql-kafka-subscriptions...

    kafka-sse-example:通过HTTP流API公开Kafka消息

    该示例项目从服务读取消息,并使用服务器发送事件(SSE)协议通过HTTP流API公开数据。 它使用Python和Django编写,并依靠来管理流连接。 设置和使用 设置virtualenv并安装依赖项: virtualenv --python=python3 ...

    kafka-ws:Kafka 包裹在 websockets 中

    kafka-websocket kafka-websocket 是一个简单的 websocket 服务器接口到 kafka 分布式消息代理。 它支持客户端订阅主题,包括一次包含多个主题,以及向主题发送消息。 消息可以是文本或二进制,每种格式如下所述。 ...

    ruoshui:基于postgresql和kafka的流处理框架

    Ruoshui是一个基于PostgreSQL和Apache Kafka的流式处理框架,在PostgreSQL许可协议下开源,采用Spring Boot开发,对外提供RESTful风格的接口。项目名称“ Ruoshui”(弱水)取自“任凭弱水三千,我只取一瓢饮”。 该...

    MaxKey(马克思的钥匙)用户单点登录认证系统(Sigle Sign On System),寓意是最大钥匙,.rar

    提供用户生命周期管理,支持SCIM 2协议,基于Apache Kafka代理,通过连接器(Connector)实现身份供给同步。 认证中心具有平台无关性、环境多样性,支持Web、手机、移动设备等, 如Apple iOS,Andriod等,将认证能力从B...

    emqx MQTT协议 服务端工具

    EMQX 内置扩展插件架构,支持以插件方式提供认证、ACL、存储接口,能非常方便的与上层物联网应用及其他 IT系统快速集成; 多种物联网协议支持。完整支持 MQTT V5.0 协议规范,并下兼容 MQTT V3.1 和 V3.1.1,还可...

    C++并行计算与异步网络引擎.rar

    目前支持http,redis,mysql和kafka协议。 轻松构建效率极高的spider。 实现自定义协议client/server,构建自己的RPC系统。 srpc就是以它为基础,作为独立项目开源。支持srpc,brpc,trpc和thrift等协议。 构建异步...

    Java思维导图xmind文件+导出图片

    Dubbo服务接口的设计原则(实战经验) Dubbo设计原理及源码分析 基于Dubbo构建大型分布式电商平台实战雏形 Dubbo容错机制及扩展性分析 分布式解决方案 分布式全局ID生成方案 session跨域共享及企业级单点登录...

    Golang mk教程-Go语言视频零基础入门到精通项目实战web编程

    第09天-高级-网络协议TCP、Redis与聊天室 第10天-高级-Web开发与Mysql数据库 第11天-高级-项目实战-日志收集系统kafka库实战 第12天-高级-etcd、contex、kafka消费实例、logagent 第13天-实战-日志管理平台开发 第14...

    springwolf-core:使用Spring Boot构建的异步API的自动化文档

    通过CLI或其他接口发布。 Springwolf利用了您已经充分描述了用户端点(带有侦听器注释,例如@KafkaListner )的事实,并自动为适当的负载生成示例负载对象,并允许您单击一下即可将其发布到正确的通道。 用法 您不...

    2017最新大数据架构师精英课程

    7_多态-接口-异常体系 8_适配器/ k% N! Y7 j/ |- c) O5 M' V6 S 9_多线程-yield-join-daemon-synchronized; o, E; \* I: E2 W 10_多线程-同步代码块-同步方法 11_多线程-生产消费问题 12_多线程-死锁问题 13_字符集...

    QPS接口耗时统计log_monitor.zip

    jeesuite统一监控平台,基于springboot jeesuite-libs构建,包括kafka监控、定时任务、性能监控、统一配置管理等 企业应用监控系统Ramona341 Ramona 是一个库或者是一个组件使得应用开发者、监控者...

    基于Spring Cloud+Netty+Sentinel+Seata+TDengine+Vue的物联网平台项目源码+数据

    设备集成:设备管理(支持MQTT协议、WebSocket协议、TCP-IP协议设备接入)、子设备管理、产品管理、协议管理、规则引擎(设备联动) 设备调试:实时日志、命令下发 规则引擎消息转发:支持KAFKA节点、HTTP节点、...

    goflow:Cloudflare内部使用的高扩展性sFlowNetFlowIPFIX收集器

    它从不同的流协议中收集网络信息(IP,接口,路由器),以protobuf格式对其进行序列化,然后使用Sarama的库将消息发送给Kafka。 为什么 Cloudflare的设备多样性和网络样本数量需要自己的管道。 我们专注于构建易于...

    sniffer-agent:嗅探器MySQL包

    本项目采用模块化设计,主要分为四大模块:TCP抓包模块,协议解析模块,输出模块,心跳模块 2. Parse Protocol sniffer-agent采用模块化结构,支持用户添加自己的解析模块,只要实现了统一的接口即可 MySQL ...

Global site tag (gtag.js) - Google Analytics