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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
