private void logMessageProcessFailed(final FetchContext request, final Throwable e) {
        StringBuilder sBuilder = new StringBuilder(512);
        sBuilder.append("CallBack process message failed: partition=").append(request.getPartition());
        sBuilder.append(", group=").append(baseConsumer.consumerConfig.getConsumerGroup());
        sBuilder.append(", FetchManager.isConsumePaused=").append(isConsumePaused());
        sBuilder.append(", MessageConsumer.shutdown=").append(isShutdown());
        if (!isShutdown()) {
            final long now = System.currentTimeMillis();
            final long lastTime = lastLogPrintTime.get();
            if ((lastFailureCount.incrementAndGet() <= MAX_FAILURE_LOG_TIMES)
                    || (lastTime <= 0 || now - lastTime > 30000)) {
                logger.warn(sBuilder.toString(), e);
                if (now - lastTime > 30000) {
                    lastLogPrintTime.set(now);
                    lastFailureCount.set(0);
                }
            }
        }
    }
A utility method that log message process failure.

@param request fetch task context
@param e       error cause
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/SimplePushMessageConsumer.java