gosonzhang opened a new pull request #339: URL: https://github.com/apache/incubator-tubemq/pull/339
The reason for this problem is that the Tubemq class is shared in the source and sink, but the required parameters required by the source and sink are inconsistent, the Tubemq.toConnectorProperties() does not check whether the corresponding required parameters are met according to different ways of use. The problem is solved by adding the consumerRole attribute (the default true, consumer role) and the role setting API asConsumer (boolean isConsumer) in the Tubemq class ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
