Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Open
clChenLiang opened this issue Dec 26, 2017 · 9 comments
Open

Comments

@clChenLiang
Copy link

                 ^

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
Copy link
Contributor

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

@clChenLiang
Copy link
Author

好的,谢谢,振东哥

@clChenLiang
Copy link
Author

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

@scheng2013
Copy link

$ 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.

  • node-rdkafka@1.0.6
    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

@scheng2013
Copy link

scheng2013 commented Jan 4, 2018

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
Copy link

打开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
Copy link
Contributor

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

@johnnychq
Copy link

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

@johnnychq
Copy link

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

4 participants