Open
Description
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?
Metadata
Metadata
Assignees
Labels
No labels