-response <- POST(url=paste(kafka_rest_proxy, "consumers", consumer, sep="/"),
- content_type("application/vnd.kafka.v2+json"),
- accept("application/vnd.kafka.v2+json"),
- body=paste0('{"name": "',
- consumer_instance,
- '", "format": "json", "auto.offset.reset": "earliest"}')
- )
-fromJSON(content(response, "text"))
+source("R/CreateKafkaConsumer.R")
+consumerDetails <- CreateKafkaConsumer(kafka.rest.proxy = kafka_rest_proxy, consumer = consumer, consumer_instance = consumer_instance)