[0_0, 0_1, 1_0, 0_2, 1_1, 1_2]
subtopology 0: zzzzzz_state
subtopology 1: command

2020-04-15 21:06:30.733  INFO 1 --- [-StreamThread-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1-consumer, groupId=XXXXCommandProcessor] Finished assignment for group at generation 3: {
XXXXCommandProcessor-0cea179f-7dbc-4a05-bc9f-e65c50a719f6-StreamThread-1-consumer-31ce2a35-db2a-427c-bdb8-bf2172044780=Assignment(partitions=[zzzzzz_state-2, mnl.xxxx.command-2, xxxx.command-2], userDataSize=325),
NODE_3 XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-2-consumer-d615472f-c2de-46eb-877f-9438ce46ac2e=Assignment(partitions=[zzzzzz_state-1], userDataSize=278),
NODE_3 XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1-consumer-c00e5aba-3183-4e16-922c-843105dc18ce=Assignment(partitions=[zzzzzz_state-0, mnl.xxxx.command-1, xxxx.command-1], userDataSize=325),
XXXXCommandProcessor-0cea179f-7dbc-4a05-bc9f-e65c50a719f6-StreamThread-2-consumer-9ad0069d-024e-43c6-9fe8-7d665a57ef02=Assignment(partitions=[mnl.xxxx.command-0, xxxx.command-0], userDataSize=256)}

2020-04-15 21:10:04.593  INFO 1 --- [-StreamThread-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1-consumer, groupId=XXXXCommandProcessor] Finished assignment for group at generation 4: {
XXXXCommandProcessor-0cea179f-7dbc-4a05-bc9f-e65c50a719f6-StreamThread-1-consumer-31ce2a35-db2a-427c-bdb8-bf2172044780=Assignment(partitions=[zzzzzz_state-2], userDataSize=268),
NODE_1 XXXXCommandProcessor-dd0be3bd-1c94-4eec-b828-091f2a1a322e-StreamThread-2-consumer-7e905888-ef63-41da-9eee-fac518d405d2=Assignment(partitions=[], userDataSize=229),
NODE_3 XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-2-consumer-d615472f-c2de-46eb-877f-9438ce46ac2e=Assignment(partitions=[zzzzzz_state-1], userDataSize=298),
NODE_3 XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1-consumer-c00e5aba-3183-4e16-922c-843105dc18ce=Assignment(partitions=[zzzzzz_state-0], userDataSize=329),
NODE_1 XXXXCommandProcessor-dd0be3bd-1c94-4eec-b828-091f2a1a322e-StreamThread-1-consumer-94aaa563-ef5b-4741-ab83-baf835bc8908=Assignment(partitions=[], userDataSize=260),
XXXXCommandProcessor-0cea179f-7dbc-4a05-bc9f-e65c50a719f6-StreamThread-2-consumer-9ad0069d-024e-43c6-9fe8-7d665a57ef02=Assignment(partitions=[mnl.xxxx.command-0, xxxx.command-0], userDataSize=306)}

<BEFORE FIRST CRASH ON NODE 1>

2020-04-15 21:10:08.952  INFO 1 --- [-StreamThread-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1-consumer, groupId=XXXXCommandProcessor] Finished assignment for group at generation 5: {
XXXXCommandProcessor-0cea179f-7dbc-4a05-bc9f-e65c50a719f6-StreamThread-1-consumer-31ce2a35-db2a-427c-bdb8-bf2172044780=Assignment(partitions=[zzzzzz_state-2], userDataSize=268),
NODE_1 XXXXCommandProcessor-dd0be3bd-1c94-4eec-b828-091f2a1a322e-StreamThread-2-consumer-7e905888-ef63-41da-9eee-fac518d405d2=Assignment(partitions=[mnl.xxxx.command-2, xxxx.command-2], userDataSize=245),
NODE_3 XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-2-consumer-d615472f-c2de-46eb-877f-9438ce46ac2e=Assignment(partitions=[zzzzzz_state-1], userDataSize=298),
NODE_3 XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1-consumer-c00e5aba-3183-4e16-922c-843105dc18ce=Assignment(partitions=[zzzzzz_state-0], userDataSize=329),
NODE_1 XXXXCommandProcessor-dd0be3bd-1c94-4eec-b828-091f2a1a322e-StreamThread-1-consumer-94aaa563-ef5b-4741-ab83-baf835bc8908=Assignment(partitions=[mnl.xxxx.command-1, xxxx.command-1], userDataSize=276),
XXXXCommandProcessor-0cea179f-7dbc-4a05-bc9f-e65c50a719f6-StreamThread-2-consumer-9ad0069d-024e-43c6-9fe8-7d665a57ef02=Assignment(partitions=[mnl.xxxx.command-0, xxxx.command-0], userDataSize=306)}

NODE_3 2020-04-15 21:11:29.853 TRACE 1 --- [-StreamThread-1] o.a.k.s.p.internals.StreamThread         : stream-thread [XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1] Committing all active tasks [0_0] and standby tasks [0_2, 1_2] since 101ms has elapsed (commit interval is 0ms)
NODE_3 2020-04-15 21:11:29.976 TRACE 1 --- [-StreamThread-2] o.a.k.s.p.internals.StreamThread         : stream-thread [XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-2] Committing all active tasks [0_1] and standby tasks [1_0] since 100ms has elapsed (commit interval is 0ms)

<FIRST CRASH ON NODE 1>
NODE_1 12020-04-15 21:11:33.961 ERROR 1 --- [-StreamThread-2] o.a.k.s.p.i.AssignedStreamsTasks         : stream-thread [XXXXCommandProcessor-dd0be3bd-1c94-4eec-b828-091f2a1a322e-StreamThread-2] Failed to process stream task 1_2 due to the following error:

<BEFORE SECOND CRASH ON NODE 3>

2020-04-15 21:11:46.382  INFO 1 --- [-StreamThread-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1-consumer, groupId=XXXXCommandProcessor] Finished assignment for group at generation 6: {
XXXXCommandProcessor-0cea179f-7dbc-4a05-bc9f-e65c50a719f6-StreamThread-1-consumer-31ce2a35-db2a-427c-bdb8-bf2172044780=Assignment(partitions=[zzzzzz_state-2], userDataSize=329),
NODE_3 XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-2-consumer-d615472f-c2de-46eb-877f-9438ce46ac2e=Assignment(partitions=[zzzzzz_state-1, mnl.xxxx.command-2, xxxx.command-2], userDataSize=314),
NODE_3 XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1-consumer-c00e5aba-3183-4e16-922c-843105dc18ce=Assignment(partitions=[zzzzzz_state-0], userDataSize=268),
NODE_1 XXXXCommandProcessor-dd0be3bd-1c94-4eec-b828-091f2a1a322e-StreamThread-1-consumer-94aaa563-ef5b-4741-ab83-baf835bc8908=Assignment(partitions=[mnl.xxxx.command-1, xxxx.command-1], userDataSize=276),
XXXXCommandProcessor-0cea179f-7dbc-4a05-bc9f-e65c50a719f6-StreamThread-2-consumer-9ad0069d-024e-43c6-9fe8-7d665a57ef02=Assignment(partitions=[mnl.xxxx.command-0, xxxx.command-0], userDataSize=306)}

2020-04-15 21:11:48.240 TRACE 1 --- [-StreamThread-1] o.a.k.s.p.internals.StreamThread         : stream-thread [XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1] Committing all active tasks [0_0] and standby tasks [0_2] since 109ms has elapsed (commit interval is 0ms)
2020-04-15 21:11:50.082 TRACE 1 --- [-StreamThread-2] o.a.k.s.p.internals.StreamThread         : stream-thread [XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-2] Committing all active tasks [0_1, 1_2] and standby tasks [1_0] since 4062ms has elapsed (commit interval is 0ms)

<SECOND CRASH ON NODE 3>
NODE_3 2020-04-15 21:11:53.683 ERROR 1 --- [-StreamThread-2] o.a.k.s.p.i.AssignedStreamsTasks         : stream-thread [XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-2] Failed to process stream task 1_2 due to the following error:

<BEFORE DUPLICATE FOUND>

2020-04-15 21:12:04.690  INFO 1 --- [-StreamThread-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1-consumer, groupId=XXXXCommandProcessor] Finished assignment for group at generation 7: {
XXXXCommandProcessor-0cea179f-7dbc-4a05-bc9f-e65c50a719f6-StreamThread-1-consumer-31ce2a35-db2a-427c-bdb8-bf2172044780=Assignment(partitions=[zzzzzz_state-1, zzzzzz_state-2], userDataSize=306),
NODE_3 XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1-consumer-c00e5aba-3183-4e16-922c-843105dc18ce=Assignment(partitions=[zzzzzz_state-0, mnl.xxxx.command-2, xxxx.command-2], userDataSize=315),
NODE_1 XXXXCommandProcessor-dd0be3bd-1c94-4eec-b828-091f2a1a322e-StreamThread-1-consumer-94aaa563-ef5b-4741-ab83-baf835bc8908=Assignment(partitions=[mnl.xxxx.command-1, xxxx.command-1], userDataSize=337),
XXXXCommandProcessor-0cea179f-7dbc-4a05-bc9f-e65c50a719f6-StreamThread-2-consumer-9ad0069d-024e-43c6-9fe8-7d665a57ef02=Assignment(partitions=[mnl.xxxx.command-0, xxxx.command-0], userDataSize=306)}

2020-04-15 21:12:06.294 TRACE 1 --- [-StreamThread-1] o.a.k.s.p.internals.StreamThread         : stream-thread [XXXXCommandProcessor-94f7be8e-beec-411f-b4ec-9031527bccdf-StreamThread-1] Committing all active tasks [0_0, 1_2] and standby tasks [0_1, 0_2] since 3ms has elapsed (commit interval is 0ms)