justinmclean commented on issue #3542: URL: https://github.com/apache/iggy/issues/3542#issuecomment-5946870699
The offset design in OFFSET_STORAGE.md won't work against the current server. I assume this is this allready know? The plan is for the gateway to save Kafka offsets in the Iggy consumer group kafka.cg.<group> without joining that group. But the server only accepts a group offset from a client that has joined the group and owns the partition. Anyone else gets error 5009 (ConsumerGroupPartitionNotOwned). The check is fence_group_offset in core/server/src/namespace.rs. I tested this on server 0.9.0. Saving an offset without joining fails with 5009, even when the group has no members. Reading the offset without joining works. So if OffsetCommit is built as the doc describes, every Kafka commit through the gateway will fail. One fix is to skip the ownership check when the group has no members. An empty group would then act as a plain offset store. Would that be acceptable on the server side? -- 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]
