+SubscribeKafkaTopic <- function(consumer.base.uri, topic) {
+ response <- POST(url=paste(consumer.base.uri,
+ "subscription", sep="/"),
+ content_type("application/vnd.kafka.v2+json"),
+ body = paste0('{"topics":["',
+ topic,
+ '"]}')
+ )
+ if(response$status_code == 204) {
+ return(response)
+ } else stop(response)
+}
\ No newline at end of file