Информация об окружающей среде
ОС [например, Ma c, Arch, Windows 10]: 4.14.138-99.102.amzn2.x86_64 / Lambda AWS linux 2
Версия узла [например, 8.2.1]: v10.18.1
NPM Версия [например, 5.4.2]: 6.13.4
C ++ Toolchain [например, Visual Studio, llvm, g ++]: g cc .x86_64 g cc -c ++. X86_64 libg cc .x86_64 версия узла-rdkafka [например, 2.3.3]: 2.7.4
Действия по воспроизведению установки узловых модулей через npm для кода запуска node-rdkafka для подключения к kafka
Пример фрагмента кода
connect() {
const self = this
this.producer = new this.Kafka.Producer(this.producer_options)
this.producer.on('event.log', (log) => {
console.log(log)
})
// Log all errors
this.producer.on('event.error', (err) => {
console.error('Error from producer')
console.error(err)
})
// Once the producer is ready resolve our earlier promise
this.producer.on('ready', () => {
self.ready_promise_resolve()
})
// Begin connecting
this.producer.connect()
return this
}
Ошибка из-за ошибки сегментации
Thread 14 "rdk:broker-1" received signal SIGSEGV, Segmentation fault.
[Switching to Thread 0x7fc246a38700 (LWP 5098)]
0x00007fc26c70d6f7 in ssl3_cleanup_key_block () from /lib64/libssl.so.10
#0 0x00007f9097db96f7 in ssl3_cleanup_key_block () from /lib64/libssl.so.10
#1 0x00007f9097db7686 in ssl3_clear () from /lib64/libssl.so.10
#2 0x00007f9097dc1929 in tls1_clear () from /lib64/libssl.so.10
#3 0x0000000001427d2f in SSL_new ()
#4 0x00007f90ac783b39 in rd_kafka_transport_ssl_connect (rkb=rkb@entry=**********, rktrans=rktrans@entry=**********,
errstr=errstr@entry=********* "sasl_ssl://dev-kafka.*****.****.com:****/bootstrap", errstr_size=errstr_size@entry=512) at rdkafka_ssl.c:475
#5 0x00007f90ac70aab2 in rd_kafka_transport_connected (rktrans=*********) at rdkafka_transport.c:640
#6 rd_kafka_transport_io_event (rktrans=rktrans@entry=*********, events=events@entry=4) at rdkafka_transport.c:728
#7 0x00007f90ac70be33 in rd_kafka_transport_io_serve (rktrans=*********, timeout_ms=1000) at rdkafka_transport.c:827
#8 0x00007f90ac6f6447 in rd_kafka_broker_ops_io_serve (rkb=rkb@entry=**********, abs_timeout=abs_timeout@entry=638224079013) at rdkafka_broker.c:3027
#9 0x00007f90ac6f77f5 in rd_kafka_broker_producer_serve (abs_timeout=638224079013, rkb=**********) at rdkafka_broker.c:3597
#10 rd_kafka_broker_serve (rkb=rkb@entry=**********, timeout_ms=<optimized out>, timeout_ms@entry=1000) at rdkafka_broker.c:4390
#11 0x00007f90ac6f8012 in rd_kafka_broker_thread_main (arg=arg@entry=**********) at rdkafka_broker.c:4432
#12 0x00007f90ac746bb7 in _thrd_wrapper_function (aArg=<optimized out>) at tinycthread.c:576
#13 0x00007f90af7df40b in start_thread () from /lib64/libpthread.so.0
#14 0x00007f90af519e7f in clone () from /lib64/libc.so.6