dockerzhang opened a new issue #671: URL: https://github.com/apache/incubator-inlong/issues/671
<p>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.</p> <p><b>Metadata</b> - Describes the currently available brokers, their host and port information, and gives information about which broker hosts which partitions.<br/> <b>Send</b> - Send messages to a broker<br/> <b>Fetch</b> - Fetch messages from a broker, one which fetches data, one which gets cluster metadata, and one which gets offset information about a topic.<br/> <b>Offsets</b> - Get information about the available offsets for a given topic partition.<br/> <b>Offset Commit</b> - Commit a set of offsets for a consumer group<br/> <b>Offset Fetch</b> - Fetch a set of offsets for a consumer group</p> <i>JIRA link - <a href="https://issues.apache.org/jira/browse/INLONG-72";>[INLONG-72]</a> created by junping_du</i> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
