[GitHub] [kafka] cadonna edited a comment on pull request #10944: MINOR: Loose verification of startup in EOS system tests

[GitBox <gi...@apache.org>]

cadonna edited a comment on pull request #10944:
URL: https://github.com/apache/kafka/pull/10944#issuecomment-871339360


   From the logs, I see the following last assignment:
   ```
   2021-06-29 09:57:45,026] INFO Decided on assignment: {
   
   016c5d71-b8a4-4e8a-9896-e757eefb68c6=[
       activeTasks: ([0_0, 0_2, 0_3]) 
       standbyTasks: ([0_1, 0_4]) 
       prevActiveTasks: ([0_0, 0_2]) 
       prevStandbyTasks: ([0_1, 0_3, 0_4]) 
       changelogOffsetTotalsByTask: ([0_0=-2, 0_1=10880, 0_2=-2, 0_3=10428, 0_4=10964]) 
       taskLagTotals: ([0_0=-2, 0_1=280, 0_2=-2, 0_3=24, 0_4=4]) 
       capacity: 1 
       assigned: 5], 
   
   3134dbd9-4def-4574-b027-427ae654d8f5=[
       activeTasks: ([0_1, 0_4]) 
       standbyTasks: ([0_0, 0_2, 0_3]) 
       prevActiveTasks: ([0_1]) 
       prevStandbyTasks: ([0_0, 0_2, 0_3, 0_4]) 
       changelogOffsetTotalsByTask: ([0_0=10226, 0_1=-2, 0_2=6254, 0_3=10448, 0_4=10680]) 
       taskLagTotals: ([0_0=580, 0_1=-2, 0_2=4998, 0_3=4, 0_4=288]) 
       capacity: 1 
       assigned: 5], 
   
   5c2faa18-0876-498a-b00d-9b5bd62297d1=[
       activeTasks: ([]) 
       standbyTasks: ([0_0, 0_1, 0_2, 0_3, 0_4]) 
       prevActiveTasks: ([]) 
       prevStandbyTasks: ([0_0, 0_1, 0_2, 0_3, 0_4]) 
       changelogOffsetTotalsByTask: ([0_0=0, 0_1=0, 0_2=0, 0_3=0, 0_4=2009]) 
       taskLagTotals: ([0_0=10806, 0_1=11160, 0_2=11252, 0_3=10452, 0_4=8959]) 
       capacity: 1 
       assigned: 5]
   } with followup probing rebalance. (org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor)
   ```
   `5c2faa18-0876-498a-b00d-9b5bd62297d1` is the Streams client that is shutdown uncleanly and verified when it restarts. The verification whether `5c2faa18-0876-498a-b00d-9b5bd62297d1` processed records will never be satisfied since the Streams client only has standby tasks.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org