TubeMQ has been donated to the Apache Software Foundation and renamed to InLong, please visit the new Apache repository: https://github.com/apache/incubator-inlong
Handling partially inconsistent string concatenation processing codes: Most of the string concatenation processing in TubeMQ uses the StringBuilder.append() method to concatenate strings, avoiding the use of the "+" operator, but some code uses both StringBuilder.append() Use the "+" operator,for example in BaseMessageConsumer.java :
if (!consumeSubInfo.isSubscribedTopicContain(partitionKeyItems[1].trim())) {
throw new TubeClientException(new StringBuilder(256)
.append("Parameter error: not included in subcribed topic list: "
+ "partOffsetMap's key is ")
.append(entry.getKey()).append(", subscribed topics are ")
.append(consumeSubInfo.getSubscribedTopics().toString()).toString());
}
Handling partially inconsistent string concatenation processing codes: Most of the string concatenation processing in TubeMQ uses the StringBuilder.append() method to concatenate strings, avoiding the use of the "+" operator, but some code uses both StringBuilder.append() Use the "+" operator,for example in BaseMessageConsumer.java :