fkzhao opened a new issue, #14353: URL: https://github.com/apache/doris/issues/14353
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/doris/issues?q=is%3Aissue) and found no similar issues. ### Version 1.14(latest) ### What's Wrong? Error Log: I1117 05:05:54.698402 4206 data_consumer.cpp:119] init kafka consumer with group id: consumer_group_mats_pinot_test I1117 05:05:54.700079 4206 data_consumer.h:94] kafka log-4-CONFWARN, event: [thrd:app]: Configuration property reconnect.backoff.jitter.ms is deprecated: No longer used. See `reconnect.backoff.ms` and `reconnect.backoff.max.ms`. I1117 05:05:55.118062 23348 data_consumer.h:94] kafka log-2-LIBSASL, event: [thrd:sasl_ssl://xxxx:9092/bootstrap]: sasl_ssl://xxxx:9092/bootstrap: Cyrus/libsasl2 is missing a GSSAPI module: make sure the libsasl2-modules-gssapi-mit or cyrus-sasl-gssapi packages are installed I1117 05:05:55.118296 23348 data_consumer.h:94] kafka log-3-FAIL, event: [thrd:sasl_ssl://xxxx:9092/bootstrap]: sasl_ssl://xxxx:9092/bootstrap: Failed to initialize SASL authentication: SASL handshake failed (start (-4)): SASL(-4): no mechanism available: No worthy mechs found (after 0ms in state AUTH_REQ) I1117 05:05:55.395835 23348 data_consumer.h:94] kafka log-2-LIBSASL, event: [thrd:sasl_ssl://xxxx:9092/bootstrap]: sasl_ssl://xxxx:9092/bootstrap: Cyrus/libsasl2 is missing a GSSAPI module: make sure the libsasl2-modules-gssapi-mit or cyrus-sasl-gssapi packages are installed I1117 05:05:55.396010 23348 data_consumer.h:94] kafka log-3-FAIL, event: [thrd:sasl_ssl://xxxx:9092/bootstrap]: sasl_ssl://xxxx:9092/bootstrap: Failed to initialize SASL authentication: SASL handshake failed (start (-4)): SASL(-4): no mechanism available: No worthy mechs found (after 0ms in state AUTH_REQ, 1 identical error(s) suppressed) I1117 05:05:56.157056 23348 data_consumer.h:94] kafka log-2-LIBSASL, event: [thrd:sasl_ssl://xxxx:9092/bootstrap]: sasl_ssl://xxxx:9092/bootstrap: Cyrus/libsasl2 is missing a GSSAPI module: make sure the libsasl2-modules-gssapi-mit or cyrus-sasl-gssapi packages are installed I1117 05:05:58.606029 23348 data_consumer.h:94] kafka log-2-LIBSASL, event: [thrd:sasl_ssl://xxxx:9092/bootstrap]: sasl_ssl://xxxx:9092/bootstrap: Cyrus/libsasl2 is missing a GSSAPI module: make sure the libsasl2-modules-gssapi-mit or cyrus-sasl-gssapi packages are installed I1117 05:05:59.149942 4218 plan_fragment_executor.cpp:78] PlanFragmentExecutor::prepare|pthread_id=140710614271744|backend_num=0|instance_id=506cb7ea05cd45f6-af505687e00d8ce6|query_id=506cb7ea05cd45f6-af505687e00d8ce5 I1117 05:05:59.150110 4218 mem_tracker_task_pool.cpp:43] Register query/load memory tracker, query/load id: 506cb7ea05cd45f6-af505687e00d8ce5 limit: 4.00 GB I1117 05:05:59.150751 3966 fragment_mgr.cpp:474] PlanFragmentExecutor::_exec_actual|pthread_id=140712007460608|instance_id=506cb7ea05cd45f6-af505687e00d8ce6|query_id=506cb7ea05cd45f6-af505687e00d8ce5 I1117 05:05:59.150785 3966 plan_fragment_executor.cpp:239] PlanFragmentExecutor::open, using query memory limit: 4.00 GB|mem_limit=4294967296|instance_id=506cb7ea05cd45f6-af505687e00d8ce6|query_id=506cb7ea05cd45f6-af505687e00d8ce5 I1117 05:05:59.150972 3966 plan_fragment_executor.cpp:702] Close() fragment_instance_id=506cb7ea05cd45f6-af505687e00d8ce6 W1117 05:05:59.700314 4206 data_consumer.cpp:279] failed to get partition meta: Local: Broker transport failure I1117 05:05:59.700417 4206 data_consumer.h:86] kafka error: Local: Authentication failure, event: sasl_ssl://xxxx:9092/bootstrap: Failed to initialize SASL authentication: SASL handshake failed (start (-4)): SASL(-4): no mechanism available: No worthy mechs found (after 0ms in state AUTH_REQ) I1117 05:05:59.700426 4206 data_consumer.h:86] kafka error: Local: All broker connections are down, event: 1/1 brokers are down I1117 05:05:59.700439 4206 data_consumer.h:86] kafka error: Local: Authentication failure, event: sasl_ssl://xxxx:9092/bootstrap: Failed to initialize SASL authentication: SASL handshake failed (start (-4)): SASL(-4): no mechanism available: No worthy mechs found (after 0ms in state AUTH_REQ, 1 identical error(s) suppressed) I1117 05:06:00.135394 3842 mem_tracker_task_pool.cpp:101] Deregister query/load memory tracker, queryId=506cb7ea05cd45f6-af505687e00d8ce5, Limit=4.00 GB, CurrUsed=17.90 KB, PeakUsed=34.49 KB ### What You Expected? Success use the kafka sasl_ssl protocol to load data to doris ### How to Reproduce? _No response_ ### Anything Else? _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
