search

AliwareMQ / aliware-kafka-demos

提供各种客户端接入阿里云 消息队列 Kafka 的demo工程(Provide a demo project for various clients to access Alibaba Cloud message queue Kafka)
https://www.aliyun.com/product/kafka
408 stars 215 forks source link

Error: Invalid value for configuration property "security.protocol" #14

Open clChenLiang opened 6 years ago

clChenLiang commented 6 years ago 
                 ^

Error: Invalid value for configuration property "security.protocol"
    at Error (native)
    at Producer.Client (/Users/souche_/projects_souche/node_modules/node-rdkafka/lib/client.js:54:18)
    at new Producer (/Users/souche_/projects_souche/node_modules/node-rdkafka/lib/producer.js:71:10)
    at Object.<anonymous> (/Users/souche_/projects_souche/test/msgQueue_ALI/producter.js:6:16)
    at Module._compile (module.js:570:32)
    at Object.Module._extensions..js (module.js:579:10)
    at Module.load (module.js:487:32)
    at tryModuleLoad (module.js:446:12)
    at Function.Module._load (module.js:438:3)
    at Module.runMain (module.js:604:10)

使用 Nodejs-demo 的 producter 时弹出这个错误。检查过 node-kafka 模块，确实是有 sasl_ssl 这个 enum value 的。改成其它值，也同样报错。

dongeforever commented 6 years ago

改成PLAINTEXT试一下呢； 如果PLAINTEXT可以，则说明librdkafka环境安装有问题：node-kafka模块是依赖librdkafka模块的；检查下librdkafka的版本； 如果PLAINTEXT也不可以，则node-kafka本身就有问题，建议重新安装一下；

clChenLiang commented 6 years ago

好的，谢谢，振东哥

clChenLiang commented 6 years ago

最终解决的方案：仅限于 Mac 系统 安装 brew ，更新 openssl 。后重新 npm install node-rdkafka.即可。 原因，Mac 中的 ssl 版本可能比 librdkafka 的版本低，所以需要更新一下。

scheng2013 commented 6 years ago

$ npm install node-rdkafka

node-rdkafka@1.0.6 install /Users/scheng/kafaka-demo/aliware-kafka-demos/kafka-nodejs-demo/node_modules/node-rdkafka node-gyp rebuild

ACTION configuring librdkafka... deps/librdkafka/config.h checking for OS or distribution... ok (osx) checking for C compiler from CC env... failed checking for gcc (by command)... ok checking for C++ compiler from CXX env... failed checking for C++ compiler (g++)... ok checking executable ld... ok checking executable nm... ok checking executable objdump... ok checking executable strip... ok checking for debug symbols compiler flag (-g...)... ok checking for pkgconfig (by command)... ok checking for install (by command)... failed checking for PIC (by compile)... ok checking for GNU-compatible linker options... failed checking for OSX linker options... ok checking for GNU linker-script ld flag... failed checking for Solaris linker-script ld flag... failed (ignore) checking for __atomic_32 (by compile)... ok checking for __atomic_64 (by compile)... ok checking for socket (by compile)... ok parsing version '0x000905ff'... ok (0.9.5) checking for libpthread (by pkg-config)... failed checking for libpthread (by compile)... ok checking for zlib (by pkg-config)... ok checking for zlib (by compile)... ok checking for libcrypto (by pkg-config)... ok checking for libcrypto (by compile)... ok checking for liblz4 (by pkg-config)... failed checking for liblz4 (by compile)... failed (disable) checking for libssl (by pkg-config)... ok checking for libssl (by compile)... ok checking for libsasl2 (by pkg-config)... failed checking for libsasl2 (by compile)... ok checking for regex (by compile)... ok checking for librt (by pkg-config)... failed checking for librt (by compile)... failed checking for strndup (by compile)... ok checking for nm (by env NM)... ok (cached) Generated Makefile.config Generated config.h

Configuration summary: prefix /usr/local ARCH x86_64 CPU generic GEN_PKG_CONFIG y ENABLE_DEVEL n ENABLE_VALGRIND n ENABLE_REFCNT_DEBUG n ENABLE_SHAREDPTR_DEBUG n ENABLE_LZ4_EXT y ENABLE_SSL y ENABLE_SASL y MKL_APP_NAME librdkafka MKL_APP_DESC_ONELINE The Apache Kafka C/C++ library MKL_DISTRO osx CC gcc CXX g++ LD ld NM nm OBJDUMP objdump STRIP strip CPPFLAGS -I/usr/local/opt/openssl/include -gstrict-dwarf -O2 -fPIC -Wall -Wsign-compare -Wfloat-equal -Wpointer-arith -Wcast-align LDFLAGS -L/usr/local/opt/openssl/lib PKG_CONFIG pkg-config INSTALL install LIB_LDFLAGS -shared -dynamiclib -Wl,-install_name,$(DESTDIR)$(libdir)/$(LIBFILENAME) RDKAFKA_VERSION_STR 0.9.5 MKL_APP_VERSION 0.9.5 LIBS -lpthread -lz -lz -L/usr/local/Cellar/openssl/1.0.2h_1/lib -lcrypto -lcrypto -L/usr/local/Cellar/openssl/1.0.2h_1/lib -lssl -lssl -lsasl2 CFLAGS -I/usr/local/Cellar/openssl/1.0.2h_1/include -I/usr/local/Cellar/openssl/1.0.2h_1/include CXXFLAGS -Wno-non-virtual-dtor SYMDUMPER $(NM) -g exec_prefix /usr/local bindir /usr/local/bin sbindir /usr/local/sbin libexecdir /usr/local/libexec datadir /usr/local/share sysconfdir /usr/local/etc sharedstatedir /usr/local/com localstatedir /usr/local/var libdir /usr/local/lib includedir /usr/local/include infodir /usr/local/info mandir /usr/local/man Generated config.cache

Now type 'make' to build TOUCH Release/obj.target/deps/librdkafka_config.stamp CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdgz.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdcrc32.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_op.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_msg.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_request.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdlog.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdavl.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_metadata_cache.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/lz4hc.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_cgrp.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/lz4frame.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/tinycthread.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_event.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/regexp.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_offset.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_topic.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_metadata.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdregex.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_subscription.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/xxhash.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_queue.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_broker.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdports.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_conf.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_assignor.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdstring.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdlist.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_range_assignor.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/lz4.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_roundrobin_assignor.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_feature.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_partition.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_timer.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdaddr.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_pattern.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/snappy.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdrand.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_transport.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_buf.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_sasl.o CC(target) Release/obj.target/librdkafka/deps/librdkafka/src/rdkafka_sasl_cyrus.o ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:66:21: warning: 'sasl_client_step' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] r = sasl_client_step(state->conn, ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:993:17: note: 'sasl_client_step' has been explicitly marked deprecated here LIBSASL_API int sasl_client_step(sasl_conn_t conn, ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:94:29: warning: 'sasl_errdetail' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] sasl_errdetail(state->conn)); ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:770:25: note: 'sasl_errdetail' has been explicitly marked deprecated here LIBSASL_API const char sasl_errdetail(sasl_conn_t conn) __OSX_AVAILABL... ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:104:21: warning: 'sasl_getprop' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] if (sasl_getprop(state->conn, SASL_USERNAME, ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:800:17: note: 'sasl_getprop' has been explicitly marked deprecated here LIBSASL_API int sasl_getprop(sasl_conn_t conn, int propnum, ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:108:21: warning: 'sasl_getprop' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] if (sasl_getprop(state->conn, SASL_MECHNAME, ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:800:17: note: 'sasl_getprop' has been explicitly marked deprecated here LIBSASL_API int sasl_getprop(sasl_conn_t conn, int propnum, ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:112:21: warning: 'sasl_getprop' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] if (sasl_getprop(state->conn, SASL_AUTHSOURCE, ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:800:17: note: 'sasl_getprop' has been explicitly marked deprecated here LIBSASL_API int sasl_getprop(sasl_conn_t conn, int propnum, ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:396:17: warning: 'sasl_dispose' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] sasl_dispose(&rktrans->rktrans_sasl.state->conn); ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:746:18: note: 'sasl_dispose' has been explicitly marked deprecated here LIBSASL_API void sasl_dispose(sasl_conn_t *pconn) __OSX_AVAILABLE_BUT_D... ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:449:13: warning: 'sasl_client_new' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] r = sasl_client_new(rk->rk_conf.sasl.service_name, hostname, ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:947:17: note: 'sasl_client_new' has been explicitly marked deprecated here LIBSASL_API int sasl_client_new(const char service, ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:454:29: warning: 'sasl_errstring' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] sasl_errstring(r, NULL, NULL)); ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:757:25: note: 'sasl_errstring' has been explicitly marked deprecated here LIBSASL_API const char sasl_errstring(int saslerr, ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:460:17: warning: 'sasl_listmech' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] sasl_listmech(state->conn, NULL, NULL, " ", NULL, ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:1102:17: note: 'sasl_listmech' has been explicitly marked deprecated here LIBSASL_API int sasl_listmech(sasl_conn_t conn, ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:471:21: warning: 'sasl_client_start' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] r = sasl_client_start(state->conn, ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:972:17: note: 'sasl_client_start' has been explicitly marked deprecated here LIBSASL_API int sasl_client_start(sasl_conn_t conn, ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:491:32: warning: 'sasl_errdetail' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] r, sasl_errdetail(state->conn)); ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:770:25: note: 'sasl_errdetail' has been explicitly marked deprecated here LIBSASL_API const char sasl_errdetail(sasl_conn_t conn) __OSX_AVAILABL... ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:591:13: warning: 'sasl_client_init' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] r = sasl_client_init(NULL); ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:924:17: note: 'sasl_client_init' has been explicitly marked deprecated here LIBSASL_API int sasl_client_init(const sasl_callback_t callbacks) __OSX... ^ ../deps/librdkafka/src/rdkafka_sasl_cyrus.c:594:25: warning: 'sasl_errstring' is deprecated: first deprecated in macOS 10.11 [-Wdeprecated-declarations] sasl_errstring(r, NULL, NULL)); ^ /Applications/Xcode.app/Contents/Developer/Platforms/MacOSX.platform/Developer/SDKs/MacOSX10.13.sdk/usr/include/sasl/sasl.h:757:25: note: 'sasl_errstring' has been explicitly marked deprecated here LIBSASL_API const char *sasl_errstring(int saslerr, ^ 13 warnings generated. LIBTOOL-STATIC Release/rdkafka.a CXX(target) Release/obj.target/librdkafka_cpp/deps/librdkafka/src-cpp/MetadataImpl.o CXX(target) Release/obj.target/librdkafka_cpp/deps/librdkafka/src-cpp/TopicPartitionImpl.o CXX(target) Release/obj.target/librdkafka_cpp/deps/librdkafka/src-cpp/TopicImpl.o CXX(target) Release/obj.target/librdkafka_cpp/deps/librdkafka/src-cpp/ConfImpl.o CXX(target) Release/obj.target/librdkafka_cpp/deps/librdkafka/src-cpp/ProducerImpl.o CXX(target) Release/obj.target/librdkafka_cpp/deps/librdkafka/src-cpp/ConsumerImpl.o CXX(target) Release/obj.target/librdkafka_cpp/deps/librdkafka/src-cpp/HandleImpl.o CXX(target) Release/obj.target/librdkafka_cpp/deps/librdkafka/src-cpp/RdKafka.o CXX(target) Release/obj.target/librdkafka_cpp/deps/librdkafka/src-cpp/QueueImpl.o CXX(target) Release/obj.target/librdkafka_cpp/deps/librdkafka/src-cpp/MessageImpl.o CXX(target) Release/obj.target/librdkafka_cpp/deps/librdkafka/src-cpp/KafkaConsumerImpl.o LIBTOOL-STATIC Release/rdkafka_cpp.a CXX(target) Release/obj.target/node-librdkafka/src/binding.o CXX(target) Release/obj.target/node-librdkafka/src/callbacks.o CXX(target) Release/obj.target/node-librdkafka/src/common.o CXX(target) Release/obj.target/node-librdkafka/src/config.o CXX(target) Release/obj.target/node-librdkafka/src/connection.o CXX(target) Release/obj.target/node-librdkafka/src/errors.o CXX(target) Release/obj.target/node-librdkafka/src/kafka-consumer.o CXX(target) Release/obj.target/node-librdkafka/src/producer.o CXX(target) Release/obj.target/node-librdkafka/src/topic.o CXX(target) Release/obj.target/node-librdkafka/src/workers.o SOLINK_MODULE(target) Release/node-librdkafka.node npm WARN kafka-nodejs-demo@1.0.0 No repository field.

scheng2013 commented 6 years ago

brew upgrade openssl Warning: You are using OS X 10.13. We do not provide support for this pre-release version. You may encounter build failures or other breakages. Please create pull-requests instead of filing issues. Error: openssl 1.0.2h_1 already installed

以上代码运行是，producer.on("ready")方法不进入也不执行，程序一会就执行退出，请帮忙指正下。谢谢。 @dongeforever @clChenLiang

scheng2013 commented 6 years ago

打开debug选项： fac: 'STATE', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE' } event.log { severity: 7, fac: 'BROADCAST', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: Broadcasting state change' } event.log { severity: 7, fac: 'SEND', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Sent SaslHandshakeRequest (v0, 28 bytes @ 0, CorrId 80)' } event.log { severity: 7, fac: 'RECV', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Received SaslHandshakeResponse (v0, 18 bytes, CorrId 80, rtt 43.21ms)' } event.log { severity: 7, fac: 'SASLMECHS', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Broker supported SASL mechanisms: PLAIN,ONS' } event.log { severity: 7, fac: 'AUTH', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Auth in state AUTH_HANDSHAKE (handshake supported)' } event.log { severity: 7, fac: 'STATE', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Broker changed state AUTH_HANDSHAKE -> AUTH' } event.log { severity: 7, fac: 'BROADCAST', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: Broadcasting state change' } event.log { severity: 7, fac: 'SASL', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Initializing SASL client: service name kafka, hostname kafka-ons-internet.aliyun.com, mechanisms PLAIN, provider PLAIN (builtin)' } event.log { severity: 7, fac: 'SASLPLAIN', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Sending SASL PLAIN (builtin) authentication token' } event.log { severity: 7, fac: 'SASL', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Send SASL frame to broker (48 bytes)' } event.log { severity: 7, fac: 'BROKERFAIL', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: failed: err: Local: Authentication failure: (errno: Invalid argument)' } event.log { severity: 7, fac: 'STATE', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Broker changed state AUTH -> DOWN' } event.log { severity: 7, fac: 'BROADCAST', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: Broadcasting state change' } event.log { severity: 7, fac: 'BUFQ', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Purging bufq with 0 buffers' } event.log { severity: 7, fac: 'BUFQ', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Updating 0 buffers on connection reset' } event.log { severity: 7, fac: 'CONNECT', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: broker in state DOWN connecting' } event.log { severity: 7, fac: 'CONNECT', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Connecting to ipv4#116.62.99.76:8080 (sasl_ssl) with socket 20' } event.log { severity: 7, fac: 'STATE', message: '[thrd:sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap]: sasl_ssl://kafka-ons-internet.aliyun.com:8080/bootstrap: Broker changed state DOWN -> CONNECT' } event.log { severity: 7, fac: 'BROADCAST',

dongeforever commented 6 years ago

@scheng2013 配置不正确吧；加入Kafka用户交流群，参考群公告里面的资料呢

johnnychq commented 6 years ago

遇到同样问题，centos， 请kafka用户交流群号码是多少呢？ @dongeforever

johnnychq commented 6 years ago

@clChenLiang 请问，问题最终解决了吗