You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tubemq.apache.org by "Guocheng Zhang (Jira)" <ji...@apache.org> on 2020/05/28 14:32:00 UTC

[jira] [Updated] (TUBEMQ-72) Support Kafka Compatible Protocol in TubeMQ

     [ https://issues.apache.org/jira/browse/TUBEMQ-72?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Guocheng Zhang updated TUBEMQ-72:
---------------------------------
    Fix Version/s: 0.7.0

> Support Kafka Compatible Protocol in TubeMQ
> -------------------------------------------
>
>                 Key: TUBEMQ-72
>                 URL: https://issues.apache.org/jira/browse/TUBEMQ-72
>             Project: Apache TubeMQ
>          Issue Type: New Feature
>            Reporter: Junping Du
>            Priority: Major
>             Fix For: 0.7.0
>
>
> The Kafka protocol is general used in MQ area, and Apache Pulsar (another MQ) did work to support it. TubeMQ should do the same thing - given there are only six core client requests APIs.
> *Metadata* - Describes the currently available brokers, their host and port information, and gives information about which broker hosts which partitions.
> *Send* - Send messages to a broker
> *Fetch* - Fetch messages from a broker, one which fetches data, one which gets cluster metadata, and one which gets offset information about a topic.
> *Offsets* - Get information about the available offsets for a given topic partition.
> *Offset Commit* - Commit a set of offsets for a consumer group
> *Offset Fetch* - Fetch a set of offsets for a consumer group



--
This message was sent by Atlassian Jira
(v8.3.4#803005)