Last active
May 16, 2019 13:21
-
-
Save dotanrs/ca3379bc688cfe2a6824e91fdf77d56c to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| kafka-node:KafkaClient Connect attempt 1 +0ms | |
| kafka-node:KafkaClient Trying to connect to host: host.docker.internal port: 9092 +2ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| consumer working... ^C to exit | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +5ms | |
| kafka-node:KafkaClient broker socket connected {"host":"host.docker.internal","port":"9092"} +2ms | |
| kafka-node:KafkaClient connected to socket, trying to load initial metadata +0ms | |
| kafka-node:KafkaClient missing apiSupport waiting until broker is ready... +1ms | |
| kafka-node:KafkaClient waitUntilReady [BrokerWrapper host.docker.internal:9092 (connected: true) (ready: false) (idle: false) (needAuthentication: false) (authenticated: false)] +0ms | |
| kafka-node:KafkaClient Received versions response from host.docker.internal:9092 +4ms | |
| kafka-node:KafkaClient setting api support to {"produce":{"min":0,"max":2,"usable":2},"fetch":{"min":0,"max":3,"usable":2},"offset":{"min":0,"max":1,"usable":0},"metadata":{"min":0,"max":2,"usable":1},"leader":{"min":0,"max":0,"usable":false},"stopReplica":{"min":0,"max":0,"usable":false},"updateMetadata":{"min":0,"max":2,"usable":false},"controlledShutdown":{"min":1,"max":1,"usable":false},"offsetCommit":{"min":0,"max":2,"usable":2},"offsetFetch":{"min":0,"max":1,"usable":1},"groupCoordinator":{"min":0,"max":0,"usable":0},"joinGroup":{"min":0,"max":1,"usable":0},"heartbeat":{"min":0,"max":0,"usable":0},"leaveGroup":{"min":0,"max":0,"usable":0},"syncGroup":{"min":0,"max":0,"usable":0},"describeGroups":{"min":0,"max":0,"usable":0},"listGroups":{"min":0,"max":0,"usable":0},"saslHandshake":{"min":0,"max":0,"usable":0},"apiVersions":{"min":0,"max":0,"usable":0},"createTopics":{"min":0,"max":0,"usable":0},"deleteTopics":{"min":0,"max":0,"usable":false}} +0ms | |
| kafka-node:KafkaClient broker is now ready +0ms | |
| kafka-node:KafkaClient updating metadatas +16ms | |
| kafka-node:ConsumerGroup Connecting kafka-node-client +0ms | |
| kafka-node:ConsumerGroup GroupCoordinator Response: { coordinatorHost: 'host.docker.internal', | |
| coordinatorPort: 9092, | |
| coordinatorId: 0 } +4ms | |
| kafka-node:ConsumerGroup joinGroupResponse {"members":[{"subscription":["ExampleTopic14"],"version":0,"id":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed"},{"subscription":["ExampleTopic14"],"version":0,"id":"kafka-node-client-075d7440-a6d7-42df-bcc2-71256d733e84"}],"generationId":4,"groupProtocol":"roundrobin","leaderId":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed","memberId":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed"} from kafka-node-client +26s | |
| kafka-node:ConsumerGroup Assigning Partitions to members [ { subscription: [ 'ExampleTopic14' ], | |
| version: 0, | |
| userData: undefined, | |
| id: 'kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed' }, | |
| { subscription: [ 'ExampleTopic14' ], | |
| version: 0, | |
| userData: undefined, | |
| id: 'kafka-node-client-075d7440-a6d7-42df-bcc2-71256d733e84' } ] +0ms | |
| kafka-node:ConsumerGroup Using group protocol roundrobin +0ms | |
| kafka-node:ConsumerGroup loadingMetadata for topics: [ 'ExampleTopic14' ] +2ms | |
| kafka-node:ConsumerGroup mapTopicToPartitions { ExampleTopic14: [ '0' ] } +4ms | |
| kafka-node:Roundrobin topicPartition: {"ExampleTopic14":["0"]} +0ms | |
| kafka-node:Roundrobin groupMembers: [{"subscription":["ExampleTopic14"],"version":0,"id":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed"},{"subscription":["ExampleTopic14"],"version":0,"id":"kafka-node-client-075d7440-a6d7-42df-bcc2-71256d733e84"}] +0ms | |
| kafka-node:Roundrobin members [ 'kafka-node-client-075d7440-a6d7-42df-bcc2-71256d733e84', | |
| 'kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed' ] +1ms | |
| kafka-node:Roundrobin subscribers { 'kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed': [ 'ExampleTopic14' ], | |
| 'kafka-node-client-075d7440-a6d7-42df-bcc2-71256d733e84': [ 'ExampleTopic14' ] } +0ms | |
| kafka-node:Roundrobin round robin on topic partition pairs: [ { topic: 'ExampleTopic14', partition: '0' } ] +0ms | |
| kafka-node:ConsumerGroup SyncGroup Request from kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed +1ms | |
| kafka-node:ConsumerGroup SyncGroup Response +91ms | |
| kafka-node:ConsumerGroup generationId 4 +0ms | |
| kafka-node:ConsumerGroup startFetch is false +0ms | |
| kafka-node:ConsumerGroup kafka-node-client is leader scheduled new topic/partition check +0ms | |
| kafka-node:ConsumerGroup kafka-node-client started heartbeats at every 10000 ms +0ms | |
| kafka-node:ConsumerGroup checking for new topics and partitions +30s | |
| kafka-node:ConsumerGroup no new Topic/Partitions +7ms | |
| kafka-node:ConsumerGroup kafka-node-client is leader scheduled new topic/partition check +0ms | |
| kafka-node:ConsumerGroup kafka-node-client Heartbeat error: { RebalanceInProgress: Kafka Error Code: 27 | |
| at new RebalanceInProgress (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/RebalanceInProgressError.js:4:9) | |
| at createGroupError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/protocol/protocol.js:210:13) | |
| at Object.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/protocol/protocol.js:1128:14) | |
| at Object.self.tap (/Users/dotanreis/src/kafka-api/node_modules/binary/index.js:248:12) | |
| at decodeGroupHeartbeatResponse (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/protocol/protocol.js:1127:87) | |
| at KafkaClient.Client.invokeResponseCallback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:634:18) | |
| at KafkaClient.Client.handleReceivedData (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:614:10) | |
| at KafkaClient.handleReceivedData (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:1340:48) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:785:10) | |
| at emitOne (events.js:116:13) message: 'Kafka Error Code: 27', errorCode: 27 } +6ms | |
| kafka-node:ConsumerGroupRecovery tryToRecoverFrom heartbeat { RebalanceInProgress: Kafka Error Code: 27 | |
| at new RebalanceInProgress (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/RebalanceInProgressError.js:4:9) | |
| at createGroupError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/protocol/protocol.js:210:13) | |
| at Object.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/protocol/protocol.js:1128:14) | |
| at Object.self.tap (/Users/dotanreis/src/kafka-api/node_modules/binary/index.js:248:12) | |
| at decodeGroupHeartbeatResponse (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/protocol/protocol.js:1127:87) | |
| at KafkaClient.Client.invokeResponseCallback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:634:18) | |
| at KafkaClient.Client.handleReceivedData (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:614:10) | |
| at KafkaClient.handleReceivedData (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:1340:48) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:785:10) | |
| at emitOne (events.js:116:13) message: 'Kafka Error Code: 27', errorCode: 27 } +2ms | |
| kafka-node:ConsumerGroupRecovery RECOVERY from heartbeat: kafka-node-client retrying in 1000 ms { RebalanceInProgress: Kafka Error Code: 27 | |
| at new RebalanceInProgress (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/RebalanceInProgressError.js:4:9) | |
| at createGroupError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/protocol/protocol.js:210:13) | |
| at Object.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/protocol/protocol.js:1128:14) | |
| at Object.self.tap (/Users/dotanreis/src/kafka-api/node_modules/binary/index.js:248:12) | |
| at decodeGroupHeartbeatResponse (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/protocol/protocol.js:1127:87) | |
| at KafkaClient.Client.invokeResponseCallback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:634:18) | |
| at KafkaClient.Client.handleReceivedData (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:614:10) | |
| at KafkaClient.handleReceivedData (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:1340:48) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:785:10) | |
| at emitOne (events.js:116:13) message: 'Kafka Error Code: 27', errorCode: 27 } +1ms | |
| kafka-node:ConsumerGroup Connecting kafka-node-client +1s | |
| kafka-node:ConsumerGroup GroupCoordinator Response: null +0ms | |
| kafka-node:ConsumerGroup joinGroupResponse {"members":[{"subscription":["ExampleTopic14"],"version":0,"id":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed"}],"generationId":5,"groupProtocol":"roundrobin","leaderId":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed","memberId":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed"} from kafka-node-client +6ms | |
| kafka-node:ConsumerGroup Assigning Partitions to members [ { subscription: [ 'ExampleTopic14' ], | |
| version: 0, | |
| userData: undefined, | |
| id: 'kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed' } ] +0ms | |
| kafka-node:ConsumerGroup Using group protocol roundrobin +1ms | |
| kafka-node:ConsumerGroup loadingMetadata for topics: [ 'ExampleTopic14' ] +0ms | |
| kafka-node:ConsumerGroup mapTopicToPartitions { ExampleTopic14: [ '0' ] } +2ms | |
| kafka-node:Roundrobin topicPartition: {"ExampleTopic14":["0"]} +0ms | |
| kafka-node:Roundrobin groupMembers: [{"subscription":["ExampleTopic14"],"version":0,"id":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed"}] +1ms | |
| kafka-node:Roundrobin members [ 'kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed' ] +0ms | |
| kafka-node:Roundrobin subscribers { 'kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed': [ 'ExampleTopic14' ] } +0ms | |
| kafka-node:Roundrobin round robin on topic partition pairs: [ { topic: 'ExampleTopic14', partition: '0' } ] +0ms | |
| kafka-node:ConsumerGroup SyncGroup Request from kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed +0ms | |
| kafka-node:ConsumerGroup SyncGroup Response +4ms | |
| kafka-node:ConsumerGroup kafka-node-client owns topics: { ExampleTopic14: [ 0 ] } +0ms | |
| kafka-node:ConsumerGroup kafka-node-client fetchOffset Response: {"ExampleTopic14":{"0":5}} +3ms | |
| kafka-node:ConsumerGroup Has saved offsets +0ms | |
| kafka-node:ConsumerGroup generationId 5 +0ms | |
| kafka-node:ConsumerGroup startFetch is true +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +2ms | |
| kafka-node:KafkaClient missing apiSupport waiting until broker is ready... +1ms | |
| kafka-node:KafkaClient waitUntilReady [BrokerWrapper host.docker.internal:9092 (connected: true) (ready: false) (idle: false) (needAuthentication: false) (authenticated: false)] +0ms | |
| kafka-node:ConsumerGroup kafka-node-client started heartbeats at every 10000 ms +0ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient Received versions response from host.docker.internal:9092 +7ms | |
| kafka-node:KafkaClient setting api support to {"produce":{"min":0,"max":2,"usable":2},"fetch":{"min":0,"max":3,"usable":2},"offset":{"min":0,"max":1,"usable":0},"metadata":{"min":0,"max":2,"usable":1},"leader":{"min":0,"max":0,"usable":false},"stopReplica":{"min":0,"max":0,"usable":false},"updateMetadata":{"min":0,"max":2,"usable":false},"controlledShutdown":{"min":1,"max":1,"usable":false},"offsetCommit":{"min":0,"max":2,"usable":2},"offsetFetch":{"min":0,"max":1,"usable":1},"groupCoordinator":{"min":0,"max":0,"usable":0},"joinGroup":{"min":0,"max":1,"usable":0},"heartbeat":{"min":0,"max":0,"usable":0},"leaveGroup":{"min":0,"max":0,"usable":0},"syncGroup":{"min":0,"max":0,"usable":0},"describeGroups":{"min":0,"max":0,"usable":0},"listGroups":{"min":0,"max":0,"usable":0},"saslHandshake":{"min":0,"max":0,"usable":0},"apiVersions":{"min":0,"max":0,"usable":0},"createTopics":{"min":0,"max":0,"usable":0},"deleteTopics":{"min":0,"max":0,"usable":false}} +1ms | |
| kafka-node:KafkaClient broker is now ready +0ms | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012414\\\"}\"","offset":5,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:13:34.214Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012414\\\"}\"","offset":6,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:13:34.844Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012415\\\"}\"","offset":7,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:13:35.412Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012415\\\"}\"","offset":8,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:13:35.930Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012416\\\"}\"","offset":9,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:13:36.419Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012502\\\"}\"","offset":10,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:15:02.860Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012503\\\"}\"","offset":11,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:15:03.729Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012504\\\"}\"","offset":12,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:15:04.528Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012505\\\"}\"","offset":13,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:15:05.222Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012505\\\"}\"","offset":14,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:15:05.900Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012536\\\"}\"","offset":15,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:15:36.351Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012537\\\"}\"","offset":16,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:15:37.463Z"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012538\\\"}\"","offset":17,"partition":0,"highWaterOffset":18,"key":"key1","timestamp":"2019-05-16T13:15:38.571Z"} | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +15s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +1ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +1ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +1ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:ConsumerGroup Error from kafka-node-client { NestedError: refreshBrokerMetadata failed | |
| at async.waterfall (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:374:35) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:473:16 | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5329:29) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:12) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| Caused By: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendHeartbeatRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:250:8) | |
| at Heartbeat.send (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroupHeartbeat.js:14:17) | |
| at ConsumerGroup.sendHeartbeat (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:671:13) | |
| at Timeout.heartbeatInterval.setInterval [as _onTimeout] (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:633:24) | |
| nested: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendHeartbeatRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:250:8) | |
| at Heartbeat.send (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroupHeartbeat.js:14:17) | |
| at ConsumerGroup.sendHeartbeat (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:671:13) | |
| at Timeout.heartbeatInterval.setInterval [as _onTimeout] (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:633:24) } +266ms | |
| Got error in consumer! | |
| { NestedError: refreshBrokerMetadata failed | |
| at async.waterfall (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:374:35) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:473:16 | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5329:29) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:12) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| Caused By: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendHeartbeatRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:250:8) | |
| at Heartbeat.send (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroupHeartbeat.js:14:17) | |
| at ConsumerGroup.sendHeartbeat (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:671:13) | |
| at Timeout.heartbeatInterval.setInterval [as _onTimeout] (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:633:24) | |
| nested: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendHeartbeatRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:250:8) | |
| at Heartbeat.send (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroupHeartbeat.js:14:17) | |
| at ConsumerGroup.sendHeartbeat (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:671:13) | |
| at Timeout.heartbeatInterval.setInterval [as _onTimeout] (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:633:24) } | |
| kafka-node:ConsumerGroup kafka-node-client Heartbeat error: { BrokerNotAvailableError: Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092 | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:231:15) | |
| at KafkaClient.Client.sendHeartbeatRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:250:8) | |
| at Heartbeat.send (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroupHeartbeat.js:14:17) | |
| at ConsumerGroup.sendHeartbeat (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:671:13) | |
| at Timeout.heartbeatInterval.setInterval [as _onTimeout] (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:633:24) | |
| at ontimeout (timers.js:482:11) | |
| at tryOnTimeout (timers.js:317:5) | |
| at Timer.listOnTimeout (timers.js:277:5) | |
| message: 'Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092' } +4ms | |
| kafka-node:ConsumerGroupRecovery tryToRecoverFrom heartbeat { BrokerNotAvailableError: Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092 | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:231:15) | |
| at KafkaClient.Client.sendHeartbeatRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:250:8) | |
| at Heartbeat.send (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroupHeartbeat.js:14:17) | |
| at ConsumerGroup.sendHeartbeat (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:671:13) | |
| at Timeout.heartbeatInterval.setInterval [as _onTimeout] (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:633:24) | |
| at ontimeout (timers.js:482:11) | |
| at tryOnTimeout (timers.js:317:5) | |
| at Timer.listOnTimeout (timers.js:277:5) | |
| message: 'Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092' } +1ms | |
| kafka-node:ConsumerGroupRecovery RECOVERY from heartbeat: kafka-node-client retrying in 1000 ms { BrokerNotAvailableError: Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092 | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:231:15) | |
| at KafkaClient.Client.sendHeartbeatRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:250:8) | |
| at Heartbeat.send (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroupHeartbeat.js:14:17) | |
| at ConsumerGroup.sendHeartbeat (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:671:13) | |
| at Timeout.heartbeatInterval.setInterval [as _onTimeout] (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:633:24) | |
| at ontimeout (timers.js:482:11) | |
| at tryOnTimeout (timers.js:317:5) | |
| at Timer.listOnTimeout (timers.js:277:5) | |
| message: 'Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +733ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:ConsumerGroup Connecting kafka-node-client +267ms | |
| kafka-node:ConsumerGroup Error from kafka-node-client { NestedError: refreshBrokerMetadata failed | |
| at async.waterfall (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:374:35) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:473:16 | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5329:29) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:12) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| Caused By: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| nested: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) } +1ms | |
| Got error in consumer! | |
| { NestedError: refreshBrokerMetadata failed | |
| at async.waterfall (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:374:35) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:473:16 | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5329:29) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:12) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| Caused By: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| nested: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) } | |
| kafka-node:ConsumerGroupRecovery tryToRecoverFrom connect { BrokerNotAvailableError: Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092 | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:231:15) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:527:9 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| message: 'Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092' } +2ms | |
| kafka-node:ConsumerGroupRecovery RECOVERY from connect: kafka-node-client retrying in 1800 ms { BrokerNotAvailableError: Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092 | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:231:15) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:527:9 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| message: 'Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092' } +1ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +734ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +1ms | |
| kafka-node:ConsumerGroup Connecting kafka-node-client +59ms | |
| kafka-node:ConsumerGroup Error from kafka-node-client { NestedError: refreshBrokerMetadata failed | |
| at async.waterfall (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:374:35) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:473:16 | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5329:29) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:12) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| Caused By: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| nested: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) } +1ms | |
| Got error in consumer! | |
| { NestedError: refreshBrokerMetadata failed | |
| at async.waterfall (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:374:35) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:473:16 | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5329:29) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:12) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| Caused By: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| nested: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) } | |
| kafka-node:ConsumerGroupRecovery tryToRecoverFrom connect { BrokerNotAvailableError: Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092 | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:231:15) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:527:9 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| message: 'Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092' } +3ms | |
| kafka-node:ConsumerGroupRecovery RECOVERY from connect: kafka-node-client retrying in 3240 ms { BrokerNotAvailableError: Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092 | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:231:15) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:527:9 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| message: 'Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092' } +8ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +932ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:ConsumerGroup Connecting kafka-node-client +1s | |
| kafka-node:ConsumerGroup Error from kafka-node-client { NestedError: refreshBrokerMetadata failed | |
| at async.waterfall (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:374:35) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:473:16 | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5329:29) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:12) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| Caused By: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| nested: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) } +1ms | |
| Got error in consumer! | |
| { NestedError: refreshBrokerMetadata failed | |
| at async.waterfall (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:374:35) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:473:16 | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5329:29) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:12) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| Caused By: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| nested: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) } | |
| kafka-node:ConsumerGroupRecovery tryToRecoverFrom connect { BrokerNotAvailableError: Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092 | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:231:15) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:527:9 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| message: 'Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092' } +2ms | |
| kafka-node:ConsumerGroupRecovery RECOVERY from connect: kafka-node-client retrying in 5832 ms { BrokerNotAvailableError: Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092 | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:231:15) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:527:9 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| message: 'Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +607ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:ConsumerGroup checking for new topics and partitions +274ms | |
| Got error in consumer! | |
| { NestedError: topic/partition change check failed | |
| at _checkTopicPartitionChange (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:293:37) | |
| at client.loadMetadataForTopics (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:321:14) | |
| at KafkaClient.loadMetadataForTopics (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:864:12) | |
| at ConsumerGroup._checkTopicPartitionChange (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:319:15) | |
| at Timeout.topicPartitionCheckTimer.setTimeout [as _onTimeout] (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:291:12) | |
| at ontimeout (timers.js:482:11) | |
| at tryOnTimeout (timers.js:317:5) | |
| at Timer.listOnTimeout (timers.js:277:5) | |
| Caused By: BrokerNotAvailableError: Broker not available (loadMetadataForTopics) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.loadMetadataForTopics (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:864:21) | |
| at ConsumerGroup._checkTopicPartitionChange (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:319:15) | |
| at Timeout.topicPartitionCheckTimer.setTimeout [as _onTimeout] (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:291:12) | |
| at ontimeout (timers.js:482:11) | |
| at tryOnTimeout (timers.js:317:5) | |
| at Timer.listOnTimeout (timers.js:277:5) | |
| nested: { BrokerNotAvailableError: Broker not available (loadMetadataForTopics) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.loadMetadataForTopics (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:864:21) | |
| at ConsumerGroup._checkTopicPartitionChange (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:319:15) | |
| at Timeout.topicPartitionCheckTimer.setTimeout [as _onTimeout] (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:291:12) | |
| at ontimeout (timers.js:482:11) | |
| at tryOnTimeout (timers.js:317:5) | |
| at Timer.listOnTimeout (timers.js:277:5) message: 'Broker not available (loadMetadataForTopics)' } } | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +731ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +1ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +1ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:ConsumerGroup Connecting kafka-node-client +201ms | |
| kafka-node:ConsumerGroup Error from kafka-node-client { NestedError: refreshBrokerMetadata failed | |
| at async.waterfall (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:374:35) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:473:16 | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5329:29) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:12) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| Caused By: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| nested: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) } +0ms | |
| Got error in consumer! | |
| { NestedError: refreshBrokerMetadata failed | |
| at async.waterfall (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:374:35) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:473:16 | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5329:29) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:12) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| Caused By: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| nested: Error: Unable to find available brokers to try | |
| at KafkaClient.getAvailableBroker (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:328:21) | |
| at async.waterfall.callback (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:369:23) | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at Object.waterfall (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5334:5) | |
| at KafkaClient.refreshBrokerMetadata (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:368:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:230:10) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) } | |
| kafka-node:ConsumerGroupRecovery tryToRecoverFrom connect { BrokerNotAvailableError: Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092 | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:231:15) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:527:9 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| message: 'Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092' } +2ms | |
| kafka-node:ConsumerGroupRecovery RECOVERY from connect: kafka-node-client retrying in 10498 ms { BrokerNotAvailableError: Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092 | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at KafkaClient.Client.sendGroupRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:231:15) | |
| at KafkaClient.Client.sendGroupCoordinatorRequest (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/baseClient.js:238:8) | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:533:21 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| at /Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:969:16 | |
| at /Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/consumerGroup.js:527:9 | |
| at nextTask (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5324:14) | |
| at next (/Users/dotanreis/src/kafka-api/node_modules/async/dist/async.js:5331:9) | |
| message: 'Broker not available: Broker socket is closed - connect ECONNREFUSED 127.0.0.1:9092' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +800ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +1ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +1ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +2ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient getApiVersions request timedout probably less than 0.10 using base support +504ms | |
| kafka-node:KafkaClient setting api support to {"produce":{"min":0,"max":1,"usable":1},"fetch":{"min":0,"max":1,"usable":1},"offset":{"min":0,"max":0,"usable":0},"metadata":{"min":0,"max":0,"usable":0},"leader":null,"stopReplica":null,"updateMetadata":null,"controlledShutdown":null,"offsetCommit":{"min":0,"max":2,"usable":2},"offsetFetch":{"min":0,"max":1,"usable":1},"groupCoordinator":{"min":0,"max":0,"usable":0},"joinGroup":{"min":0,"max":0,"usable":0},"heartbeat":{"min":0,"max":0,"usable":0},"leaveGroup":{"min":0,"max":0,"usable":0},"syncGroup":{"min":0,"max":0,"usable":0},"describeGroups":{"min":0,"max":0,"usable":0},"listGroups":{"min":0,"max":0,"usable":0},"saslHandshake":{"min":0,"max":0,"usable":0},"apiVersions":{"min":0,"max":0,"usable":0},"createTopics":{"min":0,"max":0,"usable":0},"deleteTopics":null,"describeConfigs":{"min":0,"max":0,"usable":0},"saslAuthenticate":{"min":0,"max":0,"usable":0}} +1ms | |
| kafka-node:KafkaClient getApiVersions request timedout probably less than 0.10 using base support +1ms | |
| kafka-node:KafkaClient setting api support to {"produce":{"min":0,"max":1,"usable":1},"fetch":{"min":0,"max":1,"usable":1},"offset":{"min":0,"max":0,"usable":0},"metadata":{"min":0,"max":0,"usable":0},"leader":null,"stopReplica":null,"updateMetadata":null,"controlledShutdown":null,"offsetCommit":{"min":0,"max":2,"usable":2},"offsetFetch":{"min":0,"max":1,"usable":1},"groupCoordinator":{"min":0,"max":0,"usable":0},"joinGroup":{"min":0,"max":0,"usable":0},"heartbeat":{"min":0,"max":0,"usable":0},"leaveGroup":{"min":0,"max":0,"usable":0},"syncGroup":{"min":0,"max":0,"usable":0},"describeGroups":{"min":0,"max":0,"usable":0},"listGroups":{"min":0,"max":0,"usable":0},"saslHandshake":{"min":0,"max":0,"usable":0},"apiVersions":{"min":0,"max":0,"usable":0},"createTopics":{"min":0,"max":0,"usable":0},"deleteTopics":null,"describeConfigs":{"min":0,"max":0,"usable":0},"saslAuthenticate":{"min":0,"max":0,"usable":0}} +0ms | |
| kafka-node:ConsumerGroup trying to reconnect if needed +0ms | |
| kafka-node:ConsumerGroup Connecting kafka-node-client +0ms | |
| kafka-node:ConsumerGroup trying to reconnect if needed +1ms | |
| kafka-node:ConsumerGroupRecovery tryToRecoverFrom connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +521ms | |
| kafka-node:ConsumerGroupRecovery RECOVERY from connect: kafka-node-client retrying in 18896 ms { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +2ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +1ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +2ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +2ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +3ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +2ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +2ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +2ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +999ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +2ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +2ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +999ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +1ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +2ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +999ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +1ms | |
| kafka-node:KafkaClient ApiVersions failed with unexpected error { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient error initializing broker after connect { BrokerNotAvailableError: Broker not available (socket closed) | |
| at new BrokerNotAvailableError (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/errors/BrokerNotAvailableError.js:11:9) | |
| at Socket.<anonymous> (/Users/dotanreis/src/kafka-api/node_modules/kafka-node/lib/kafkaClient.js:772:19) | |
| at emitOne (events.js:116:13) | |
| at Socket.emit (events.js:211:7) | |
| at TCP._handle.close [as _onclose] (net.js:567:12) message: 'Broker not available (socket closed)' } +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1s | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient kafka-node-client reconnecting to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient createBroker host.docker.internal 9092 +0ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +1ms | |
| kafka-node:KafkaClient Sending versions request to host.docker.internal:9092 +0ms | |
| kafka-node:KafkaClient getApiVersions request timedout probably less than 0.10 using base support +501ms | |
| kafka-node:KafkaClient setting api support to {"produce":{"min":0,"max":1,"usable":1},"fetch":{"min":0,"max":1,"usable":1},"offset":{"min":0,"max":0,"usable":0},"metadata":{"min":0,"max":0,"usable":0},"leader":null,"stopReplica":null,"updateMetadata":null,"controlledShutdown":null,"offsetCommit":{"min":0,"max":2,"usable":2},"offsetFetch":{"min":0,"max":1,"usable":1},"groupCoordinator":{"min":0,"max":0,"usable":0},"joinGroup":{"min":0,"max":0,"usable":0},"heartbeat":{"min":0,"max":0,"usable":0},"leaveGroup":{"min":0,"max":0,"usable":0},"syncGroup":{"min":0,"max":0,"usable":0},"describeGroups":{"min":0,"max":0,"usable":0},"listGroups":{"min":0,"max":0,"usable":0},"saslHandshake":{"min":0,"max":0,"usable":0},"apiVersions":{"min":0,"max":0,"usable":0},"createTopics":{"min":0,"max":0,"usable":0},"deleteTopics":null,"describeConfigs":{"min":0,"max":0,"usable":0},"saslAuthenticate":{"min":0,"max":0,"usable":0}} +0ms | |
| kafka-node:KafkaClient getApiVersions request timedout probably less than 0.10 using base support +1ms | |
| kafka-node:KafkaClient setting api support to {"produce":{"min":0,"max":1,"usable":1},"fetch":{"min":0,"max":1,"usable":1},"offset":{"min":0,"max":0,"usable":0},"metadata":{"min":0,"max":0,"usable":0},"leader":null,"stopReplica":null,"updateMetadata":null,"controlledShutdown":null,"offsetCommit":{"min":0,"max":2,"usable":2},"offsetFetch":{"min":0,"max":1,"usable":1},"groupCoordinator":{"min":0,"max":0,"usable":0},"joinGroup":{"min":0,"max":0,"usable":0},"heartbeat":{"min":0,"max":0,"usable":0},"leaveGroup":{"min":0,"max":0,"usable":0},"syncGroup":{"min":0,"max":0,"usable":0},"describeGroups":{"min":0,"max":0,"usable":0},"listGroups":{"min":0,"max":0,"usable":0},"saslHandshake":{"min":0,"max":0,"usable":0},"apiVersions":{"min":0,"max":0,"usable":0},"createTopics":{"min":0,"max":0,"usable":0},"deleteTopics":null,"describeConfigs":{"min":0,"max":0,"usable":0},"saslAuthenticate":{"min":0,"max":0,"usable":0}} +0ms | |
| kafka-node:ConsumerGroup Connecting kafka-node-client +7s | |
| kafka-node:ConsumerGroup GroupCoordinator Response: { coordinatorHost: 'host.docker.internal', | |
| coordinatorPort: 9092, | |
| coordinatorId: 0 } +3ms | |
| kafka-node:ConsumerGroup joinGroupResponse {"members":[{"subscription":["ExampleTopic14"],"version":0,"id":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed"}],"generationId":6,"groupProtocol":"roundrobin","leaderId":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed","memberId":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed"} from kafka-node-client +31ms | |
| kafka-node:ConsumerGroup Assigning Partitions to members [ { subscription: [ 'ExampleTopic14' ], | |
| version: 0, | |
| userData: undefined, | |
| id: 'kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed' } ] +0ms | |
| kafka-node:ConsumerGroup Using group protocol roundrobin +0ms | |
| kafka-node:ConsumerGroup loadingMetadata for topics: [ 'ExampleTopic14' ] +0ms | |
| kafka-node:ConsumerGroup mapTopicToPartitions { ExampleTopic14: [ '0' ] } +7ms | |
| kafka-node:Roundrobin topicPartition: {"ExampleTopic14":["0"]} +1ms | |
| kafka-node:Roundrobin groupMembers: [{"subscription":["ExampleTopic14"],"version":0,"id":"kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed"}] +0ms | |
| kafka-node:Roundrobin members [ 'kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed' ] +0ms | |
| kafka-node:Roundrobin subscribers { 'kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed': [ 'ExampleTopic14' ] } +0ms | |
| kafka-node:Roundrobin round robin on topic partition pairs: [ { topic: 'ExampleTopic14', partition: '0' } ] +0ms | |
| kafka-node:ConsumerGroup SyncGroup Request from kafka-node-client-e055d6b4-e747-44f2-82f2-d4e07500b1ed +0ms | |
| kafka-node:ConsumerGroup SyncGroup Response +108ms | |
| kafka-node:ConsumerGroup kafka-node-client owns topics: { ExampleTopic14: [ 0 ] } +0ms | |
| kafka-node:ConsumerGroup kafka-node-client fetchOffset Response: {"ExampleTopic14":{"0":5}} +3ms | |
| kafka-node:ConsumerGroup Has saved offsets +0ms | |
| kafka-node:ConsumerGroup generationId 6 +0ms | |
| kafka-node:ConsumerGroup startFetch is true +0ms | |
| kafka-node:ConsumerGroup kafka-node-client is leader scheduled new topic/partition check +0ms | |
| kafka-node:ConsumerGroup kafka-node-client started heartbeats at every 10000 ms +0ms | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012414\\\"}\"","offset":22,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012414\\\"}\"","offset":23,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012415\\\"}\"","offset":24,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012415\\\"}\"","offset":25,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012416\\\"}\"","offset":26,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012502\\\"}\"","offset":27,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012503\\\"}\"","offset":28,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012504\\\"}\"","offset":29,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012505\\\"}\"","offset":30,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012505\\\"}\"","offset":31,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012536\\\"}\"","offset":32,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012537\\\"}\"","offset":33,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| received {"topic":"ExampleTopic14","value":"\"{\\\"message\\\":\\\"this is the message: 1558012538\\\"}\"","offset":34,"partition":0,"highWaterOffset":18,"key":"key1"} | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +113ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +12ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +16ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +11ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +10ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +12ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +10ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +12ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +11ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +12ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +10ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +11ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +10ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +10ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +11ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +10ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +11ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +12ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +11ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +14ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +11ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +11ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +12ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +10ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +13ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +10ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +15ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +10ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +12ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +7ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +14ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +10ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +7ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +14ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +10ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +7ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +9ms | |
| kafka-node:ConsumerGroup replacing ExampleTopic14-0 stale offset of 35 with 0 +8ms |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment