KafkaConfig extends Config { String managementPathPattern(String postfix) { var builder = new StringBuilder("/_sys/kafka"); if (name != null) builder.append('/').append(name); builder.append(postfix); return builder.toString(); }  void uri(String uri); MessagePublisher<T> publish(Class<T> messageClass); MessagePublisher<T> publish(String topic, Class<T> messageClass); void subscribe(String topic, Class<T> messageClass, MessageHandler<T> handler); void subscribe(String topic, Class<T> messageClass, BulkMessageHandler<T> handler); void groupId(String groupId); void poolSize(int poolSize); void maxProcessTime(Duration maxProcessTime); void longConsumerDelayThreshold(Duration threshold); void maxPoll(int maxRecords, int maxBytes); void minPoll(int minBytes, Duration maxWaitTime);  }
@Test void managementPathPattern() { assertThat(config.managementPathPattern("/topic/:topic")).isEqualTo("/_sys/kafka/topic/:topic"); config.name = "name"; assertThat(config.managementPathPattern("/topic/:topic")).isEqualTo("/_sys/kafka/name/topic/:topic"); }