[org.apache.kafka.connect.runtime.rest.RestServer]
connect | 2025-09-03 04:51:58,330 ERROR || Failed to flush data for db: example_db, table: test_tbl after 0 times retry, the last exception is [com.starrocks.data.load.stream.v2.TransactionTableRegion]
connect | java.lang.RuntimeException: com.starrocks.streamload.shade.org.apache.http.conn.HttpHostConnectException: Connect to 127.0.0.1:8040 [/127.0.0.1] failed: Connection refused (Connection refused)
connect | at com.starrocks.data.load.stream.TransactionStreamLoader.doBegin(TransactionStreamLoader.java:165)
connect | at com.starrocks.data.load.stream.TransactionStreamLoader.begin(TransactionStreamLoader.java:103)
connect | at com.starrocks.data.load.stream.DefaultStreamLoader.send(DefaultStreamLoader.java:174)
connect | at com.starrocks.data.load.stream.v2.TransactionTableRegion.streamLoad(TransactionTableRegion.java:411)
connect | at com.starrocks.data.load.stream.v2.TransactionTableRegion.flush(TransactionTableRegion.java:271)
connect | at com.starrocks.data.load.stream.v2.StreamLoadManagerV2.lambda$init$0(StreamLoadManagerV2.java:221)
connect | at java.base/java.lang.Thread.run(Thread.java:829)
connect | Caused by: com.starrocks.streamload.shade.org.apache.http.conn.HttpHostConnectException: Connect to 127.0.0.1:8040 [/127.0.0.1] failed: Connection refused (Connection refused)
connect | at com.starrocks.streamload.shade.org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:156)
connect | at com.starrocks.streamload.shade.org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:376)
connect | at com.starrocks.streamload.shade.org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:393)
connect | at com.starrocks.streamload.shade.org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:236)
connect | at com.starrocks.streamload.shade.org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186)
connect | at com.starrocks.streamload.shade.org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89)
connect | at com.starrocks.streamload.shade.org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110)
connect | at com.starrocks.streamload.shade.org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)
connect | at com.starrocks.streamload.shade.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)
connect | at com.starrocks.streamload.shade.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108)
connect | at com.starrocks.data.load.stream.TransactionStreamLoader.doBegin(TransactionStreamLoader.java:137)