thjaeckle commented on issue #11703: URL: https://github.com/apache/iceberg/issues/11703#issuecomment-2523319487
I now figured out (by adding some more logs to the Iceberg connector) that at this point: https://github.com/apache/iceberg/blob/38c8daa4eae8a75ab46571f1efce1609100f53dd/kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/CommitterImpl.java#L68 The group state is not `ConsumerGroupState.STABLE`, but in my case `DEAD`. This method seems however only be executed once after startup .. So when at this point there is no "STABLE" consumer group state, no `Coordinator` will be started ever. Is this intended? Am I missing something? -- 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: issues-unsubscr...@iceberg.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For additional commands, e-mail: issues-h...@iceberg.apache.org
