src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java [169:175]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        return sendResult;
                    } catch (Exception e) {
                        LOG.error("Failed to send message, topic={}", message.getTopic(), e);
                        throw new RuntimeException(e);
                    }
                },
                MoreExecutors.directExecutor());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java [218:224]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        return sendResult;
                    } catch (Exception e) {
                        LOG.error("Failed to send message, topic={}", message.getTopic(), e);
                        throw new RuntimeException(e);
                    }
                },
                MoreExecutors.directExecutor());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -