Implement TopicAdminService

Implement Java SpringBoot service org.opengroup.osdu.streaming.service.TopicAdminService.java used by StreamingAdminService to perform Kafka topics manipulations:

  • createTopic method should create the new topic and set the number following parameters:
    • topicName = kind
    • partitions = 10
    • replicas = 3
  • deleteTopic method should delete the topic using topicName provided as an argument
  • test for every method above
Edited by Dmitry Kniazev