Comments (9)
改成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.
Related Issues (20)
- 求erlang demo
- node kafka连接后一直报错
- Plz support PHP
- pykafka 生产消息时报UnknownError
- filebeat demo 配置在商业版 kafka 会出错 connection reset by peer HOT 1
- springboot 2.0不兼容 HOT 6
- 关于Spring Cloud Stream Kafka Demo的配置问题 HOT 1
- logstash 配置sasl_mechanism ONS 传输失效
- 没有spring boot demo HOT 1
- php在调用producer发送消息时如何设置不需要等待进程结束 HOT 1
- 在升级或者宕机时,会发生少量消息乱序(某个分区挂掉后把消息 Failover 到其它分区)是怎么实现的? HOT 3
- 为啥没有.net的直接sdk,如果歧视.net就别给我发邮件了 HOT 1
- Go README需要更新了
- confluent-kafka-dotnet 也是兼容阿里云 kafkamq的是吗
- go confluent客户端 跨平台编译报错 HOT 1
- 使用docker起go sdk的一个producer,返回证书验证失败的错误 HOT 1
- confluent-kafka-go 在1.7.0之后已经支持windows,不能提供个完整demo吗?
- Cpp VPC-SSL demo 一直报SSL错误 HOT 3
- 报错:java: 无法访问java.time.Duration 找不到java.time.Duration的类文件 HOT 1
- kafka-nodejs-demo ssl报错
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from aliware-kafka-demos.