New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Static consumers support #1282

Open

xtrime-ru opened this issue Jul 20, 2024 · 0 comments

xtrime-ru commented Jul 20, 2024 •

edited

Loading

Currently its difficult to create static consumers because group.instance.id property is not supported:

curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" -H "Accept: application/vnd.kafka.v2+json" \
       -d '{"group.instance.id": "my_consumer_instance", "format": "json", "auto.offset.reset": "earliest"}' \
       http://localhost:8082/consumers/my_json_consumer

{"error_code":422,"message":"Unrecognized field: group.instance.id"}

It is possible to use KAFKA_REST_CONSUMER_GROUP_INSTANCE_ID env variable, but in this case all consumers have same group.instance.id.

Are there any plans to add this property to consumers constructor?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment