vl-kp commented on PR #12609:
URL: https://github.com/apache/iceberg/pull/12609#issuecomment-2756183687
> iceberg.connect.group-id this should be the consumer group ID, as this is
used to get the info on the consumer group. If this is not provided or wrongly
provided then that is probably a miss on the config side.
> Also, if you see the logic of "containsFirstPartition", in case the
member.size() == 0, it will throw "ConnectException: No partitions assigned,
cannot determine leader". So we will ultimately get an exception.
Yes, i agree that it is a configuration issue, but the problem is there
should have some warning or error log showing there is a problem, as even I
enabled DEBUG log, nothing seems useful, it is because the group state is DEAD
instead of STABLE
```
if (groupDesc.state() == ConsumerGroupState.STABLE) {
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
