THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
public class ForwardingAdminClient implements Admin {
private final Admin delegate;
public ForwardingAdminClient(final Admin delegate) {
this.del
egate = delegate;
}
@Override
public void close(Duration timeout) {
delegate.close();
}
@Override
public CreateTopicsResult createTopics(Collection<NewTopic> newTopics, CreateTopicsOptions options) {
return delegate.createTopics(newTopics, options);
}
// override rest of Admin interface to use delegate...
} |
...