[GitHub] [inlong] DavidYoungdj commented on issue #4972: [Feature] Add TubeMQ Command Tools

[GitBox <gi...@apache.org>]

DavidYoungdj commented on issue #4972:
URL: https://github.com/apache/inlong/issues/4972#issuecomment-1201146314

   ### Purpose
     Add TubeMQ command tools like the kafka command tools.We can create/delete the topics,produce/consume the message.
   ### Plan
   #### About creating / deleting a topic
   
   1. Set parameters to add / remove topics based on the type of parameter passed in.
   2. Call the client's code to create the admin of the client
   3. Check whether the partitions are correct and handle other exceptions. For example, the partitions must be greater than 0
   4. Make the network request and have the server of the Controller role accept the request processing logic
   5. Perform calibration check
   6. The data is stored in the master node
   
   #### Generating / consume information
   
   - Producer
   
   1. Set necessary parameters, such as obtaining server metadata, conditions for successfully writing data, and retry times
   2. Create TubeMQproducer
   3. Determine the topic, key, and message body to send
   4. Send the message
   
   - Consumer
   
   1. If the topic is empty, the exception is handled. Otherwise, the subscription status is reset and the subscription information and metadata are updated
   2. Ensuring thread Safety
   3. It can communicate with Cluster, register Consumer with Coordinator, and pull and update metadata
   4. Sends all requests to be sent and processes all received responses
   


-- 
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: commits-unsubscribe@inlong.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org