Webpack build fails after upgrade from postcss-cssnext 2.9.0 to 2.10.0

hello there. I tried upgrading from 2.9.0 t0 2.10.0 and now getting the error below when I do a Webpack build. I can't tell if this is a Webpack bug, cssnext bug, caniuse bug, or something else.
any ideas? thanks in advance
> npm run webpack

><EMAIL_ADDRESS>webpack /Users/tandemseven/Github/Tandemseven/mWeb
> webpack --config "config/webpack.build.prod" --optimize-minimize --progress -p

/Users/tandemseven/Github/Tandemseven/mWeb/node_modules/postcss-cssnext/node_modules/caniuse-api/dist/index.js:69
    return data.stats[browser[0]] && data.stats[browser[0]][browser[1]] === "y";
               ^

TypeError: Cannot read property 'stats' of undefined
    at /Users/tandemseven/Github/Tandemseven/mWeb/node_modules/postcss-cssnext/node_modules/caniuse-api/dist/index.js:69:16
    at Array.every (native)
    at isSupported (/Users/tandemseven/Github/Tandemseven/mWeb/node_modules/postcss-cssnext/node_modules/caniuse-api/dist/index.js:68:6)
    at /Users/tandemseven/Github/Tandemseven/mWeb/node_modules/postcss-cssnext/lib/index.js:69:117
    at Array.forEach (native)
    at /Users/tandemseven/Github/Tandemseven/mWeb/node_modules/postcss-cssnext/lib/index.js:56:35
    at creator (/Users/tandemseven/Github/Tandemseven/mWeb/node_modules/postcss/lib/postcss.js:150:35)
    at Object.<anonymous> (/Users/tandemseven/Github/Tandemseven/mWeb/config/webpack.js:59:37)
    at Module._compile (module.js:571:32)
    at Object.Module._extensions..js (module.js:580:10)
    at Module.load (module.js:488:32)
    at tryModuleLoad (module.js:447:12)
    at Function.Module._load (module.js:439:3)
    at Module.require (module.js:498:17)
    at require (internal/module.js:20:19)
    at Object.<anonymous> (/Users/tandemseven/Github/Tandemseven/mWeb/config/webpack.build.prod.js:3:34)
    at Module._compile (module.js:571:32)
    at Object.Module._extensions..js (module.js:580:10)
    at Module.load (module.js:488:32)
    at tryModuleLoad (module.js:447:12)
    at Function.Module._load (module.js:439:3)
    at Module.require (module.js:498:17)

Looks like a caniuse-api issue. Can you try upgrading this package if possible?

thanks for responding.
I don't have caniuse-api as a direct dependency of my project.
it's a dependency of postcss-cssnext - /Users/tandemseven/Github/Tandemseven/mWeb/node_modules/postcss-cssnext/node_modules/caniuse-api/dist/index.js
that version of caniuse-api which postcss-cssnext is using is "version": "1.5.3" which I believe is the latest version

Same here with Rollup.
/Frontend-Starter-Kit/node_modules/caniuse-api/dist/index.js:69
    return data.stats[browser[0]] && data.stats[browser[0]][browser[1]] === "y";
               ^

So I ran into this too, and did some digging. The issue is not so much the version of caniuse-api (since the caret specified that that would be used with 2.9.0 as well), but rather the addition of colorHexAlpha: ["css-rrggbbaa"], in #345. Re-commenting that out removes the error for me.
I've submitted #358 to at least be able to release another version that successfully builds. The root cause of course still needs investigation.

I actually did some more digging. The problem seems to be that, one way or another, version 1.0.30000590 of caniuse-db gets installed, which is not the latest version and does not contain an entry for the css-rrggbbaa feature. The odd thing is that the latest release of caniuse-api, which lists it as a dependency, has it pegged to version ^1.0.30000346 - which I interpret to mean that it should install the latest release, 1.0.30000636 - which does have data on  css-rrggbbaa.
I'm not sure why that doesn't happen. Perhaps there's a different package locking caniuse-db to a lower version, and then Yarn (which I use) thinking that using that is fine too.

All right, I think I've figured it out, with a proper fix this time (sorry for the comment spam). The reason 1.0.30000590 was installed was, I think, simply because it already was installed, so in Yarn's view it was good enough to just leave that be.
I think it can be forced to install at least the correct version by specifying it as a peerDependency. Since I don't have that much experience with publishing libraries I don't know how to test this, though, so I can't be 100% sure.
Anyway, I've submitted that as #359.

@Vinnl thanks man! had the same issue using postcss + postcss-cssnext directly, but only on travis with cached node_modules dir. deleting the node_modules caches on travis fixed it I believe ... does that make sense?

@thisconnect Yes, that makes sense. node_modules still contained the old version of caniuse-db, which for all it knew satisfied the requirements (even though it didn't). Deleting that made it fetch the newest version, which also satisfied all known requirements - and also the actual requirements :)

I also experience this issue when I use some CI tools. I use Circle CI and whenever it tests my code, it alerts cannot read property 'stats' of undefined and then fail. I guess that CI tool cannot determine which version of caniuse-db package to use.

correspoding to @Vinnl 's answer, had the same issue, and the same fix worked for npm shrinkwrap.

I've deleted directories caniuse-api and caniuse-db, and run npm install.
Thanks @Vinnl

Upgrading Gatsby to 2.10.0 broke webpack builds. Pinning to 2.9.0 until this is fixed.

... this sure has been around awhile considering this no longer works at all without manually fixing it

#369 incorporated the same fix as #359, so that should solve this issue.

Can you try with 2.11.0 ?

npm WARN<EMAIL_ADDRESS>requires a peer of<EMAIL_ADDRESS>but none was installed.  not working for me

nevermind, I saw a suggestion to clear cache.  I had to remove my node_modules dir locally and clear cache in CircleCI to get the build to go through.

having the same issue on 2.11

You need to respect the peer dep yourself. 2.11 specifiy the correct deps.

@datajohnny Try npm i caniuse-db -D or yarn add caniuse-db -D

This issue is indeed happening again with 2.11.0 (see #381). I've submitted #380 to fix this, but until then, either clear your node_modules or, if you're using Yarn, modify your yarn.lock to use at least 1.0.30000670 of caniuse-db as described in this comment.

Also reported here: https://github.com/Fyrd/caniuse/issues/3441


recall support

Hi,
Is recall at different depths supported by the tool?

Hi @Fatima-Haouari,
Unfortunately, this is a missing feature (https://github.com/joaopalotti/trectools/blob/1e6bc613c5c2fca8fe4a37e998559ee4aef649da/trectools/trec_eval.py#L143).
Would you like to give it a try and implement it?
Best,
Joao

That is the same issue raised on Issue #17, right?

Dear all, I would also like to use trectools to calculate Recall@k, I created a pull request with an initial proposal.
Best regards,
Maik


Update Puppeteer and add Windows testing on Travis

Fixes #154.
/cc @XhmikosR

/cc @XhmikosR

@vladikoff I don't see why you merged this when AppVeyor is also present.

@XhmikosR we can give it a try and remove it later, no big deal.

@XhmikosR AppVeyor is great, but I think some users of grunt-contrib-qunit will prefer to use only one CI system and might pick Travis for testing Windows if they are already familiar with that.
Per https://github.com/gruntjs/grunt-contrib-qunit/issues/154, the problem with Chrome only affected Windows Server 2016 (used at Travis), it did not affect AppVeyor (which currently uses Windows Server 2012, I think).
The AppVeyor tests for grunt-contrib-qunit, as well as the AppVeyor tests for qunitjs/qunit were passing. The easiest way to ensure that grunt-contrib-qunit stays green for Windows on Travis, was to add a test for exactly that :)
If AppVeyor can be configured to test both Windows versions, then that would also cover it. But, I do not know AppVeyor well enough to know how to do that.

I don't really care which is used as long as only one is used.
On Sun, Dec 30, 2018, 10:21 Timo Tijhof<EMAIL_ADDRESS>wrote:

@XhmikosR https://github.com/XhmikosR AppVeyor is great, but I think
some users of grunt-contrib-qunit will prefer to use only one CI system and
might pick Travis for testing Windows if they are already familiar with
that.
Per #154 https://github.com/gruntjs/grunt-contrib-qunit/issues/154, the
problem with Chrome only affected Windows Server 2016 (used at Travis), it
did not affect AppVeyor (which currently uses Windows Server 2012, I think).
The AppVeyor tests for grunt-contrib-qunit, as well as the AppVeyor tests
for qunitjs/qunit were passing. The easiest way to ensure that
grunt-contrib-qunit stays green for Windows on Travis, was to add a test
for exactly that :)
If AppVeyor can be configured to test both Windows versions, then that
would also cover it. But, I do not know AppVeyor well enough to know how to
do that.
—
You are receiving this because you were mentioned.
Reply to this email directly, view it on GitHub
https://github.com/gruntjs/grunt-contrib-qunit/pull/155#issuecomment-450545890,
or mute the thread
https://github.com/notifications/unsubscribe-auth/AAVVtdzS_K7_HdKlgJF4hroEw7TDNpKeks5u-HdwgaJpZM4ZkSjd
.


Authorization Listener should always be notified

Added Authorization Status Listener should always be informed on Authorization Change not only if the status is notDetermined or restricted.

thank you!


Adding Partitions Didn't Trigger Group Join Event

Describe the bug
We increased the partitions on a topic to meet the demands of incoming traffic. The addition to partitions did not trigger a rebalance for our consumers or producers.
To Reproduce
If none of the above are possible to provide, please write down the exact steps to reproduce the behavior:

Run a producer that continuously produces messages to a topic
Run a consumer that subscribes to that topic and logs each topic offset
Send some messages
Increase partition count
GROUP_JOIN event did not trigger

Expected behavior
If the partition count changes, causing a rebalance, then I expect the GROUP_JOIN event would trigger the new partition map.
Observed behavior
The consumer/producer continued as if no changes to partition count change.
Environment:

KafkaJS version [1.12.0]
Kafka version [2.3.1]
NodeJS version [12]

It won't detect immediately, but it constantly updates the metadata which should return the new partitions. I just did a quick check and indeed there is nothing in the code triggering a rebalance, but the information is there, it would be possible to add this.

Actually, this should work, I will write a test to confirm
https://github.com/tulios/kafkajs/blob/4139127f39616e3700b1c396053b2401be0c343a/src/consumer/consumerGroup.js#L605-L622

Yeah, it would be good to know the expected trigger rate of this. In our case, it didn't trigger within 12 hours. We bounced the consumers to get the new partitions.

More updates... I am seeing the WARN of the resync needed but it doesn't trigger the group join event. Below is the screenshot of when I triggered two separate partition updates.

As soon as that is logged, we should be rejoining and syncing. Could you run your test with debug logging so we can see what happens?

@Nevon unless there is another place to do it, the above screenshot should be logging all the messages produced by KafkaJS. Let me know if not then I can get another one.

It looks like you are running with INFO log level. You can dial that up to DEBUG to get more detailed logs: https://kafka.js.org/docs/configuration#logging
const { Kafka, logLevel } = require('kafkajs')

const kafka = new Kafka({
  clientId: 'my-app',
  brokers: ['kafka1:9092', 'kafka2:9092'],
  logLevel: logLevel.ERROR
})

Below are the stdout/stderr for the consumer. I am logging rebalance when the rebalance callback is invoked. We started with 1 partition and will see Fetching from 1 partitions for 1 out of 1 topics. We then updated the partition count to 2 and then see  Topic has been updated, resync group and subsequent Fetching from 2 partitions for 1 out of 1 topics. But what you wont see is the rebalance callback being invoked again.
{"level":"DEBUG","timestamp":"2020-10-31T12:45:50.796Z","logger":"kafkajs","message":"[Connection] Connecting","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","ssl":true,"sasl":false}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.020Z","logger":"kafkajs","message":"[Connection] Request ApiVersions(key: 18, version: 2)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":0,"expectResponse":true,"size":21}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.081Z","logger":"kafkajs","message":"[Connection] Response ApiVersions(key: 18, version: 2)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":0,"size":278,"data":{"errorCode":0,"apiVersions":[{"apiKey":0,"minVersion":0,"maxVersion":7},{"apiKey":1,"minVersion":0,"maxVersion":10},{"apiKey":2,"minVersion":0,"maxVersion":5},{"apiKey":3,"minVersion":0,"maxVersion":7},{"apiKey":4,"minVersion":0,"maxVersion":2},{"apiKey":5,"minVersion":0,"maxVersion":1},{"apiKey":6,"minVersion":0,"maxVersion":5},{"apiKey":7,"minVersion":0,"maxVersion":2},{"apiKey":8,"minVersion":0,"maxVersion":6},{"apiKey":9,"minVersion":0,"maxVersion":5},{"apiKey":10,"minVersion":0,"maxVersion":2},{"apiKey":11,"minVersion":0,"maxVersion":4},{"apiKey":12,"minVersion":0,"maxVersion":2},{"apiKey":13,"minVersion":0,"maxVersion":2},{"apiKey":14,"minVersion":0,"maxVersion":2},{"apiKey":15,"minVersion":0,"maxVersion":2},{"apiKey":16,"minVersion":0,"maxVersion":2},{"apiKey":17,"minVersion":0,"maxVersion":1},{"apiKey":18,"minVersion":0,"maxVersion":2},{"apiKey":19,"minVersion":0,"maxVersion":3},{"apiKey":20,"minVersion":0,"maxVersion":3},{"apiKey":21,"minVersion":0,"maxVersion":1},{"apiKey":22,"minVersion":0,"maxVersion":1},{"apiKey":23,"minVersion":0,"maxVersion":2},{"apiKey":24,"minVersion":0,"maxVersion":1},{"apiKey":25,"minVersion":0,"maxVersion":1},{"apiKey":26,"minVersion":0,"maxVersion":1},{"apiKey":27,"minVersion":0,"maxVersion":0},{"apiKey":28,"minVersion":0,"maxVersion":2},{"apiKey":29,"minVersion":0,"maxVersion":1},{"apiKey":30,"minVersion":0,"maxVersion":1},{"apiKey":31,"minVersion":0,"maxVersion":1},{"apiKey":32,"minVersion":0,"maxVersion":2},{"apiKey":33,"minVersion":0,"maxVersion":1},{"apiKey":34,"minVersion":0,"maxVersion":1},{"apiKey":35,"minVersion":0,"maxVersion":1},{"apiKey":36,"minVersion":0,"maxVersion":1},{"apiKey":37,"minVersion":0,"maxVersion":1},{"apiKey":38,"minVersion":0,"maxVersion":1},{"apiKey":39,"minVersion":0,"maxVersion":1},{"apiKey":40,"minVersion":0,"maxVersion":1},{"apiKey":41,"minVersion":0,"maxVersion":1},{"apiKey":42,"minVersion":0,"maxVersion":1},{"apiKey":43,"minVersion":0,"maxVersion":0}],"throttleTime":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.081Z","logger":"kafkajs","message":"[Broker] Verified support for SaslAuthenticate","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","supportAuthenticationProtocol":true}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.084Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":1,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.146Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":1,"size":231,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"INFO","timestamp":"2020-10-31T12:45:51.147Z","logger":"kafkajs","message":"[Consumer] Starting","groupId":"1604148350794"}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.147Z","logger":"kafkajs","message":"[Connection] Connecting","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","ssl":true,"sasl":false}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.344Z","logger":"kafkajs","message":"[Broker] Verified support for SaslAuthenticate","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","supportAuthenticationProtocol":true}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.346Z","logger":"kafkajs","message":"[Connection] Request GroupCoordinator(key: 10, version: 1)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":0,"expectResponse":true,"size":37}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.414Z","logger":"kafkajs","message":"[Connection] Response GroupCoordinator(key: 10, version: 1)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":0,"size":74,"data":{"throttleTime":0,"errorCode":0,"errorMessage":null,"coordinator":{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094}}}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.414Z","logger":"kafkajs","message":"[Cluster] Found group coordinator","nodeId":2}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.419Z","logger":"kafkajs","message":"[Connection] Request JoinGroup(key: 11, version: 4)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":2,"expectResponse":true,"size":100}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.494Z","logger":"kafkajs","message":"[Connection] Response JoinGroup(key: 11, version: 4)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","error":"The group member needs to have a valid member id before actually entering a consumer group","correlationId":2,"payload":{"type":"Buffer","data":"[filtered]"}}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:51.494Z","logger":"kafkajs","message":"[Connection] Request JoinGroup(key: 11, version: 4)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":3,"expectResponse":true,"size":144}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.568Z","logger":"kafkajs","message":"[Connection] Response JoinGroup(key: 11, version: 4)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":3,"size":196,"data":{"throttleTime":0,"errorCode":0,"generationId":1,"groupProtocol":"RoundRobinAssigner","leaderId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","members":[{"memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","memberMetadata":{"type":"Buffer","data":[0,1,0,0,0,1,0,4,116,101,115,116,0,0,0,0]}}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.568Z","logger":"kafkajs","message":"[ConsumerGroup] Chosen as group leader","groupId":"1604148350794","generationId":1,"memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","topics":["test"]}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.569Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":1,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.638Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":1,"size":231,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.638Z","logger":"kafkajs","message":"[ConsumerGroup] Group assignment","groupId":"1604148350794","generationId":1,"groupProtocol":"RoundRobinAssigner","assignment":[{"memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","memberAssignment":{"type":"Buffer","data":[0,1,0,0,0,1,0,4,116,101,115,116,0,0,0,1,0,0,0,0,0,0,0,0]}}],"topics":["test"]}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.641Z","logger":"kafkajs","message":"[Connection] Request SyncGroup(key: 14, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":4,"expectResponse":true,"size":164}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.744Z","logger":"kafkajs","message":"[Connection] Response SyncGroup(key: 14, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":4,"size":38,"data":{"throttleTime":0,"errorCode":0,"memberAssignment":{"type":"Buffer","data":[0,1,0,0,0,1,0,4,116,101,115,116,0,0,0,1,0,0,0,0,0,0,0,0]}}}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.744Z","logger":"kafkajs","message":"[ConsumerGroup] Received assignment","groupId":"1604148350794","generationId":1,"memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","memberAssignment":{"test":[0]}}
rebalance
{"level":"INFO","timestamp":"2020-10-31T12:45:54.744Z","logger":"kafkajs","message":"[Runner] Consumer has joined the group","groupId":"1604148350794","memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","leaderId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","isLeader":true,"memberAssignment":{"test":[0]},"groupProtocol":"RoundRobinAssigner","duration":3597}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.747Z","logger":"kafkajs","message":"[Connection] Request OffsetFetch(key: 9, version: 3)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":5,"expectResponse":true,"size":54}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.813Z","logger":"kafkajs","message":"[Connection] Response OffsetFetch(key: 9, version: 3)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":5,"size":40,"data":{"throttleTime":0,"responses":[{"topic":"test","partitions":[{"partition":0,"offset":"-1","metadata":"","errorCode":0}]}],"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.815Z","logger":"kafkajs","message":"[Connection] Request ListOffsets(key: 2, version: 2)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":2,"expectResponse":true,"size":52}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.876Z","logger":"kafkajs","message":"[Connection] Response ListOffsets(key: 2, version: 2)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":2,"size":44,"data":{"throttleTime":0,"responses":[{"topic":"test","partitions":[{"partition":0,"errorCode":0,"timestamp":"-1","offset":"0"}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.877Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:54.889Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":3,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:59.950Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":3,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:45:59.953Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":6,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:00.019Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":6,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:00.019Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:00.020Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":4,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:05.081Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":4,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:05.081Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":7,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:05.141Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":7,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:05.141Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":8,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:05.225Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":8,"size":231,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:05.225Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:05.225Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":5,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:10.288Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":5,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:10.289Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":9,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:10.352Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":9,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:10.352Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:10.352Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":6,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:15.413Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":6,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:15.413Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":10,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:15.476Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":10,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:15.476Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":7,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:15.539Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":7,"size":231,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:15.539Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:15.539Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":8,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:20.602Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":8,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:20.602Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":11,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:20.668Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":11,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:20.668Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:20.669Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":9,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:25.730Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":9,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:25.730Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":12,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:25.792Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":12,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:25.792Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":10,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:25.853Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":10,"size":231,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:25.853Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:25.853Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":11,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:30.915Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":11,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:30.915Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":13,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:30.977Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":13,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:30.977Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:30.977Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":12,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:36.039Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":12,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:36.039Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":14,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:36.100Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":14,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:36.100Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":15,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:36.162Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":15,"size":231,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:36.162Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:36.162Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":13,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:41.223Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":13,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:41.223Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":16,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:41.286Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":16,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:41.286Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:41.286Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":14,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:46.348Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":14,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:46.348Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":17,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:46.410Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":17,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:46.410Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":15,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:46.470Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":15,"size":231,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:46.470Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:46.470Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":16,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:51.531Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":16,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:51.532Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":18,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:51.597Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":18,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:51.597Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:51.597Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":17,"expectResponse":true,"size":92}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.656Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":17,"size":66,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.656Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":19,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.717Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":19,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.717Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":20,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.779Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":20,"size":261,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"WARN","timestamp":"2020-10-31T12:46:56.779Z","logger":"kafkajs","message":"[ConsumerGroup] Topic has been updated, resync group","groupId":"1604148350794","memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","topic":"test","unknownPartitions":[1]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.779Z","logger":"kafkajs","message":"[Connection] Request GroupCoordinator(key: 10, version: 1)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":18,"expectResponse":true,"size":37}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.841Z","logger":"kafkajs","message":"[Connection] Response GroupCoordinator(key: 10, version: 1)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":18,"size":74,"data":{"throttleTime":0,"errorCode":0,"errorMessage":null,"coordinator":{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094}}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.841Z","logger":"kafkajs","message":"[Cluster] Found group coordinator","nodeId":2}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.841Z","logger":"kafkajs","message":"[Connection] Request JoinGroup(key: 11, version: 4)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":21,"expectResponse":true,"size":144}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.904Z","logger":"kafkajs","message":"[Connection] Response JoinGroup(key: 11, version: 4)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":21,"size":196,"data":{"throttleTime":0,"errorCode":0,"generationId":2,"groupProtocol":"RoundRobinAssigner","leaderId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","members":[{"memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","memberMetadata":{"type":"Buffer","data":[0,1,0,0,0,1,0,4,116,101,115,116,0,0,0,0]}}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.904Z","logger":"kafkajs","message":"[ConsumerGroup] Chosen as group leader","groupId":"1604148350794","generationId":2,"memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","topics":["test"]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.905Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":19,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.968Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":19,"size":261,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.968Z","logger":"kafkajs","message":"[ConsumerGroup] Group assignment","groupId":"1604148350794","generationId":2,"groupProtocol":"RoundRobinAssigner","assignment":[{"memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","memberAssignment":{"type":"Buffer","data":[0,1,0,0,0,1,0,4,116,101,115,116,0,0,0,2,0,0,0,0,0,0,0,1,0,0,0,0]}}],"topics":["test"]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:56.968Z","logger":"kafkajs","message":"[Connection] Request SyncGroup(key: 14, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":22,"expectResponse":true,"size":168}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:57.036Z","logger":"kafkajs","message":"[Connection] Response SyncGroup(key: 14, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":22,"size":42,"data":{"throttleTime":0,"errorCode":0,"memberAssignment":{"type":"Buffer","data":[0,1,0,0,0,1,0,4,116,101,115,116,0,0,0,2,0,0,0,0,0,0,0,1,0,0,0,0]}}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:57.036Z","logger":"kafkajs","message":"[ConsumerGroup] Received assignment","groupId":"1604148350794","generationId":2,"memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","memberAssignment":{"test":[0,1]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:57.037Z","logger":"kafkajs","message":"[Runner] Error while fetching data, trying again...","groupId":"1604148350794","memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125","error":"Topic has been updated","stack":"KafkaJSStaleTopicMetadataAssignment: Topic has been updated\n    at ConsumerGroup.checkForStaleAssignment (C:\\Users\\Jordan\\GitHub\\kafkajs-playground\\node_modules\\kafkajs\\src\\consumer\\consumerGroup.js:610:15)\n    at ConsumerGroup.fetch (C:\\Users\\Jordan\\GitHub\\kafkajs-playground\\node_modules\\kafkajs\\src\\consumer\\consumerGroup.js:348:12)\n    at processTicksAndRejections (internal/process/task_queues.js:97:5)\n    at async Runner.fetch (C:\\Users\\Jordan\\GitHub\\kafkajs-playground\\node_modules\\kafkajs\\src\\consumer\\runner.js:283:22)\n    at async C:\\Users\\Jordan\\GitHub\\kafkajs-playground\\node_modules\\kafkajs\\src\\consumer\\runner.js:417:9","retryCount":0,"retryTime":312}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:57.360Z","logger":"kafkajs","message":"[Connection] Request OffsetFetch(key: 9, version: 3)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":23,"expectResponse":true,"size":58}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:57.422Z","logger":"kafkajs","message":"[Connection] Response OffsetFetch(key: 9, version: 3)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":23,"size":56,"data":{"throttleTime":0,"responses":[{"topic":"test","partitions":[{"partition":0,"offset":"-1","metadata":"","errorCode":0},{"partition":1,"offset":"-1","metadata":"","errorCode":0}]}],"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:57.422Z","logger":"kafkajs","message":"[Connection] Request ListOffsets(key: 2, version: 2)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":20,"expectResponse":true,"size":64}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:57.497Z","logger":"kafkajs","message":"[Connection] Response ListOffsets(key: 2, version: 2)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":20,"size":66,"data":{"throttleTime":0,"responses":[{"topic":"test","partitions":[{"partition":0,"errorCode":0,"timestamp":"-1","offset":"0"},{"partition":1,"errorCode":0,"timestamp":"-1","offset":"0"}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:57.497Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:46:57.497Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":21,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:02.556Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":21,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:02.557Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":24,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:02.617Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":24,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:02.617Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:02.617Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":22,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:07.677Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":22,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:07.677Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":25,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:07.740Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":25,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:07.740Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":26,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:07.803Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":26,"size":261,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:07.803Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:07.803Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":23,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:12.863Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":23,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:12.863Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":27,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:12.924Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":27,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:12.925Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:12.925Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":24,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:17.985Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":24,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:17.985Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":28,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:18.049Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":28,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:18.049Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":29,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:18.110Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":29,"size":261,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:18.110Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:18.110Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":25,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:23.173Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":25,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:23.173Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":30,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:23.233Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":30,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:23.233Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:23.234Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":26,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:28.294Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":26,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:28.294Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":31,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:28.356Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":31,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:28.356Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":27,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:28.417Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":27,"size":261,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:28.417Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:28.417Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":28,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:33.479Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":28,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:33.479Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":32,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:33.540Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":32,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:33.540Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:33.541Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":29,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:38.602Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":29,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:38.602Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":33,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:38.664Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":33,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:38.665Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":30,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:38.726Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":30,"size":261,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:38.726Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:38.726Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":31,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:43.787Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":31,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:43.787Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":34,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:43.847Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":34,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:43.847Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:43.848Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":32,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:48.906Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":32,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:48.906Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":35,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:48.972Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":35,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:48.972Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":33,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:49.033Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":33,"size":261,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:49.033Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:49.034Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":34,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:54.095Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":34,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:54.095Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":36,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:54.156Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":36,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:54.157Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:54.157Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":35,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:59.227Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":35,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:59.227Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":37,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:59.288Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":37,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:59.288Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":38,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:59.350Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":38,"size":261,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:59.350Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:47:59.350Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":36,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:04.410Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":36,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:04.410Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":39,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:04.475Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":39,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:04.475Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:04.476Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":37,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:09.537Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":37,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:09.537Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":40,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:09.611Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":40,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:09.611Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":41,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:09.671Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":41,"size":261,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:09.672Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:09.672Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":38,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:14.733Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":38,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:14.733Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":42,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:14.795Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":42,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:14.796Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:14.796Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":39,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:19.860Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":39,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:19.860Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":43,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:19.926Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":43,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:19.926Z","logger":"kafkajs","message":"[Connection] Request Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":44,"expectResponse":true,"size":32}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:19.990Z","logger":"kafkajs","message":"[Connection] Response Metadata(key: 3, version: 5)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":44,"size":261,"data":{"throttleTime":0,"brokers":[{"nodeId":2,"host":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az1"},{"nodeId":1,"host":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com","port":9094,"rack":"use1-az6"}],"clusterId":"KDPm3vdDTfOFpc3SrE7Qqg","controllerId":1,"topicMetadata":[{"topicErrorCode":0,"topic":"test","isInternal":false,"partitionMetadata":[{"partitionErrorCode":0,"partitionId":0,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]},{"partitionErrorCode":0,"partitionId":1,"leader":1,"replicas":[1],"isr":[1],"offlineReplicas":[]}]}]}}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:19.990Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:19.990Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":40,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:25.051Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":40,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:25.051Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":45,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:25.116Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":45,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:25.116Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 2 partitions for 1 out of 1 topics","topics":["test"],"activeTopicPartitions":[{"topic":"test","partitions":[0,1]}],"pausedTopicPartitions":[]}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:25.116Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":41,"expectResponse":true,"size":120}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:30.169Z","logger":"kafkajs","message":"[Runner] stop consumer group","groupId":"1604148350794","memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125"}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:30.169Z","logger":"kafkajs","message":"[Runner] waiting for consumer to finish...","groupId":"1604148350794","memberId":"kafkajs-09e6cfa4-0d4f-449f-a5d3-fd4e3ce51125"}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:30.179Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 10)","broker":"b-1.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":41,"size":104,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:30.179Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":46,"expectResponse":true,"size":86}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:30.238Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":46,"size":10,"data":{"throttleTime":0,"errorCode":0}}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:30.241Z","logger":"kafkajs","message":"[Connection] Request LeaveGroup(key: 13, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":47,"expectResponse":true,"size":82}
{"level":"DEBUG","timestamp":"2020-10-31T12:48:30.306Z","logger":"kafkajs","message":"[Connection] Response LeaveGroup(key: 13, version: 1)","broker":"b-2.aiuzs03.gknqdx.c11.kafka.us-east-1.amazonaws.com:9094","clientId":"kafkajs","correlationId":47,"size":10,"data":{"throttleTime":0,"errorCode":0}}

#937 should fix this. I vaguely remember that when we introduced this event we only wanted to trigger it once, rather than on every subsequent group rebalance, but I can't really think of why we wanted that, so I'm changing it now to make sure that it's always emitted when we go through a join + sync.

@Nevon - cool! I will watch for a release and rerun my tests! Thanks for your help on this!

1.15.0-beta.16 is out now along with this fix. Hope it does the trick for you!


kubeadm reset will no longer drain nodes automatically

https://kubernetes.io/docs/setup/independent/create-cluster-kubeadm/#tear-down

https://kubernetes.io/docs/tasks/administer-cluster/safely-drain-node/

kubectl drain
https://github.com/kubernetes/kubernetes/blob/master/pkg/kubectl/cmd/drain.go

AWS;
http://docs.aws.amazon.com/AutoScaling/latest/APIReference/API_DetachInstances.html
GCE:
https://cloud.google.com/compute/docs/reference/latest/instanceGroupManagers/abandonInstances

[ ] Select nodes from NodeList.


News app

Related to #34

The work on the feature is not finished, but these changes will be merged because there will be no further work on the project.


Split export extensions into 2

So this is more of a refactor
exportExtensions:
Proposal 1: export v from "mod"
Proposal 2: export * as ns from "mod"
Like in https://github.com/babel/babel/pull/6080 except for the babylon plugin.
exportDefault?
exportNamespace?

Check contributing https://github.com/babel/babylon/blob/master/CONTRIBUTING.md#creating-a-new-plugin-spec-new

[ ] Comment below you are going to do this (for others to know)
[ ] Read CONTRIBUTING.md
[ ] Split the plugins into 2
[ ] fix all the test fixtures (may need 2 folders, pass the correct option down)

Would like to work on this !

Hi I would like to help with this.👍

I am not sure how far above my level this is, but I would like to give it a shot, just so I understand correctly, What this is trying to do is change something like this:
export default () => {
    throw new Error('test');
};

Out:
Error: test
    at exports.default

into something like this:
let baz = () => {
    throw new Error('test');
};

export default baz;

Out:
Error: test
    at baz

@pudility sounds good, but do you mind if we check if @rajikaimal has made any progress first (just want to make sure they didn't make a bunch of effort on it)?

Definitely, how should we check?

Just see if he responds. If not by tomorrow, I'd say go for it.

Great! Will do.

Before I set up my babylon environment and test it more thoroughly, I would really appreciate it if someone would look over my code just to make sure that I am doing everything correctly. Thank you!

@pudility just to be clear, this task is to split up the exportExtensions plugin inside of Babylon into exportDefault and exportNamespace since they are two separate proposals.
Check out the link to CONTRIBUTING in the original post by @hzoo for info on adding a new plugin. The Babel side was completed in https://github.com/babel/babel/pull/6080.

So the thing I made already exists, but what still needs to be made is something for exportNamespaces? For example, something like this:
exports.hello = () => {}

@pudility this task is a refactor; there is no behavior to implement - we need to split the logic.
https://github.com/babel/babylon/blob/65bea96544561c68bdf84fa9f85bc7afdd3535c8/src/parser/statement.js#L1266-L1274 so that this.hasPlugin("exportExtensions") is split

exportextensions used to be 1 proposal and now its 2.
export-default-from https://github.com/babel/proposals/issues/17
export-ns-from https://github.com/babel/proposals/issues/16
they are indepdent and at different stages so we should split them up. you just need to change this.hasPlugin to use 2 new strings, update the readme/docs, and update the folders/tests

Ok, thank you so much for explaining, I now get it. I will give it a shot, but I am not quite sure if I will be able to do it fully.

@hzoo I think this may be a bit above my current skill level. I am going to keep looking through the code, but I don't think that I will be able to solve this issue. Thanks again for the help.

It should be as simple as using two separate plugin strings. Right now, we have one string ("exportExtensions") that enables two separate features. We want to remove that string, and instead replace it with ("exportDefault" and "exportNamespace").

Oh, Thats simpler than I thought. I just added that, I will update the docs and then create a PR.

So I have modified the code to now look like this:
  parseExport(node: N.Node): N.Node {
    // export * from '...'
    if (this.shouldParseExportStar()) {
      this.parseExportStar(node, (
        this.hasPlugin("exportDefault") ||
        this.hasPlugin("exportNamespace")
      ));
      if (node.type === "ExportAllDeclaration") return node;
    } else if (this.hasPlugin("exportDefault")) {

and I replace export-expressions with export-default and export-namespace. I also changed the options.json file in both of them to use the plug in "exportDefault" and "exportNamespace" respectively. I think that I must have done something wrong here (probably when modifying statement.js) because when I run yarn run test-only I get three errors:
  4223 passed
  3 failed
  112 skipped

  index › experimental/export default/default

  /Users/zoe/Developer/babylon/split-export/babylon/test/helpers/runFixtureTests.js:21

   20:               name + "/" + task.actual.filename + ": " + err.message;
   21:             t.fail(message);
   22:           }

  experimental/export-default/default/actual.js: Unexpected token, expected { (1:7)

plus two almost identical errors:
2. experimental/export-namespace/ns/actual.js: Unexpected token (1:9)
3.  experimental/export-default/default-type-without-flow/actual.js: Unexpected token, expected { (1:7)

Thank you all so much for helping me create my first real contribution to Babylon, I really like getting to learn the process for all of this stuff.


Ambitus

@jabostian We have Ambitus scheduled for an annual review during the TAC meeting on September 12, 2024 at 1:00p ET - are you available for this?