THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
public class ForwardingAdmin implements Admin {
private final Admin delegate;
public ForwardingAdmin(Map<String, Object> config, Admin delegate) {
this.delegate = delegate;
}
public ForwardingAdmin(Map<String, Object> config) {
this.delegate = AdminClient.create(config);
}
@Override
public CreateTopicsResult createTopics(Collection<NewTopic> newTopics, CreateTopicsOptions options) {
return delegate.createTopics(newTopics, options);
}
// override rest of Admin interface to use delegate...
} |
...