search

nodefluent / node-sinek

:tophat: Most advanced high level Node.js Kafka client
MIT License
290 stars 52 forks source link

unable to connect to confluentinc/cp-kafka:5.2.2 #166

Closed maikelmclauflin closed 3 years ago

maikelmclauflin commented 3 years ago

getting the following error when i try to connect. using the following inputs

eyeshade-consumer    | kafka 2020-12-08T21:23:16.250Z kafka consuming ["local.grant.suggestion","local.payment.vote","local.promo.referral","local.settlement.payout"] {"noptions":{"metadata.broker.list":"kafka:19092","group.id":"local.eyeshade","client.id":"local.eyeshade","socket.keepalive.enable":true,"compression.codec":"none","api.version.request":true,"socket.blocking.max.ms":100,"security.protocol":"SSL","ssl.certificate.location":"/etc/kafka/secrets/cert-signed","ssl.key.location":"/etc/kafka/secrets/ca-key","ssl.ca.location":"/etc/kafka/secrets/ca-cert","ssl.key.password":"nodesinek"},"tconf":{"request.required.acks":1,"auto.offset.reset":"earliest"}}
eyeshade-consumer    | {"level":"ERROR","timestamp":"2020-12-08T21:23:30.733Z","logger":"kafkajs","message":"[BrokerPool] Cannot read property 'toUpperCase' of undefined","retryCount":5,"retryTime":14132}

more below

eyeshade-consumer    | sentry 2020-12-08T21:23:26.109Z sentry KafkaJSNumberOfRetriesExceeded: Connection error: connect ECONNREFUSED 172.28.0.5:19092
eyeshade-consumer    |     at TLSSocket.onError (/usr/src/app/node_modules/kafkajs/src/network/connection.js:140:23)
eyeshade-consumer    |     at TLSSocket.emit (events.js:315:20)
eyeshade-consumer    |     at TLSSocket.EventEmitter.emit (domain.js:486:12)
eyeshade-consumer    |     at emitErrorNT (internal/streams/destroy.js:106:8)
eyeshade-consumer    |     at emitErrorCloseNT (internal/streams/destroy.js:74:3)
eyeshade-consumer    |     at processTicksAndRejections (internal/process/task_queues.js:80:21)
eyeshade-consumer    | From previous event:
eyeshade-consumer    |     at /usr/src/app/node_modules/sinek/dist/lib/kafkajs/JSConsumer.js:221:36
eyeshade-consumer    | From previous event:
eyeshade-consumer    |     at JSConsumer._connectInFlow (/usr/src/app/node_modules/sinek/dist/lib/kafkajs/JSConsumer.js:202:16)
eyeshade-consumer    |     at JSConsumer.connect (/usr/src/app/node_modules/sinek/dist/lib/kafkajs/JSConsumer.js:171:21)
eyeshade-consumer    |     at /usr/src/app/bat-utils/lib/runtime-kafka.js:136:22
eyeshade-consumer    |     at Array.map (<anonymous>)
eyeshade-consumer    |     at Kafka.consume (/usr/src/app/bat-utils/lib/runtime-kafka.js:133:29)
eyeshade-consumer    |     at Object.<anonymous> (/usr/src/app/eyeshade/consumer.js:35:15)
eyeshade-consumer    |     at Module._compile (internal/modules/cjs/loader.js:1063:30)
eyeshade-consumer    |     at Object.Module._extensions..js (internal/modules/cjs/loader.js:1092:10)
eyeshade-consumer    |     at Module.load (internal/modules/cjs/loader.js:928:32)
eyeshade-consumer    |     at Function.Module._load (internal/modules/cjs/loader.js:769:14)
eyeshade-consumer    |     at Function.executeUserEntryPoint [as runMain] (internal/modules/run_main.js:72:12)
eyeshade-consumer    |     at internal/main/run_main_module.js:17:47

i'm honestly wondering if this is just a docker image compatability issue?