mwkang opened a new issue, #8046: URL: https://github.com/apache/storm/issues/8046
Hi Storm maintainers, I’m currently working on integrating Kafka static membership with Storm, specifically by setting the `group.instance.id` property in Kafka consumers. In Kubernetes environments, it's relatively straightforward to assign a stable value (e.g., using the Pod UID) to `group.instance.id`. However, in Apache Storm, I haven’t found an obvious way to assign a unique and stable identifier to each consumer instance. It seems that Storm workers or tasks don't have any persistent or externally visible ID that can be used for this purpose, which makes it challenging to use Kafka static membership effectively. I have a few questions: - Is there any existing identifier within Storm (e.g., worker ID, task ID) that could be used as a stable `group.instance.id`? - If not, are there any recommended workarounds to achieve this? - Would it be feasible to consider adding a feature that allows users to inject a stable instance ID (perhaps via configuration or environment variable) for use with Kafka consumers? Any suggestions or guidance would be appreciated. Thank you for your time and for maintaining this great project! -- 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...@storm.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
