Error: Invalid value for configuration property "security.protocol" about aliware-kafka-demos HOT 9 OPEN

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

from aliware-kafka-demos.

好的，谢谢，振东哥

from aliware-kafka-demos.

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

from aliware-kafka-demos.

$ npm install node-rdkafka

[email protected] 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 [email protected] No repository field.

• [email protected]
  updated 1 package in 45.18s
  schengdeMacBook-Pro:kafka-nodejs-demo scheng$ node producer.js
  features:gzip,snappy,ssl,sasl,regex,lz4
  0.9.5

from aliware-kafka-demos.

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

from aliware-kafka-demos.

打开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',

from aliware-kafka-demos.

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

from aliware-kafka-demos.

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

from aliware-kafka-demos.

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

from aliware-kafka-demos.