@Override
                        public void handleError(Throwable error) {
                            producerManager.getClientMetrics().bookFailRpcCall(
                                    TErrCodeConstants.UNSPECIFIED_ABNORMAL);
                            partition.increRetries(1);
                            brokerRcvQltyStats.addReceiveStatistic(brokerId, false);
                            cb.onException(error);
                        }
Check if the given topic accept publish message.

@param topic topic name
@return if accept message
@throws TubeClientException
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/producer/SimpleMessageProducer.java