Problem we are seeing is that the rest proxy is replacing the consumer specified in the request to restproxy with consumer-$alphanuemeric _value and passing it to Kafka.Confluent REST Proxy API Reference | Confluent Documentation
Is there is any setting(parameter) that will let restproxy know to use exact consumer instead of any alpha numeric alias consumer name?
rick
22 June 2021 15:49
2
@Sudhanshu The request supports an id field, which should do what you want. The documentation is not accurate here, so i’ll file an issue on that.
}
/**
* Creates a new consumer instance and returns its unique ID.
*
* @param group Name of the consumer group to join
* @param instanceConfig configuration parameters for the consumer
* @return Unique consumer instance ID
*/
public String createConsumer(String group, ConsumerInstanceConfig instanceConfig) {
// The terminology here got mixed up for historical reasons, and remaining compatible moving
// forward is tricky. To maintain compatibility, if the 'id' field is specified we maintain
// the previous behavior of using it's value in both the URLs for the consumer (i.e. the
// local name) and the ID (consumer.id setting in the consumer). Otherwise, the 'name' field
// only applies to the local name. When we replace with the new consumer, we may want to
// provide an alternate app name, or just reuse the name.
String name = instanceConfig.getName();
if (instanceConfig.getId() != null) { // Explicit ID request always overrides name
name = instanceConfig.getId();
}
if (name == null) {
In the meantime, you could try adding an id to your request to see if the behavior is as you wish.
