Commit a2763692 authored by Stephen Nimmo's avatar Stephen Nimmo
Browse files

Added comments

parent bcee2653
Pipeline #69445 failed with stages
in 3 minutes and 46 seconds
......@@ -53,7 +53,7 @@ public class StorageClientFactory extends AbstractFactoryBean<IStorageFactory> {
}
@Override
protected IStorageFactory createInstance() throws Exception {
protected IStorageFactory createInstance() {
logger.debug("Creating instance of IStorageFactory... " + this.getClass().getName());
return new StorageFactory(StorageAPIConfig.builder().rootUrl(STORAGE_API).build(), bodyMapper);
}
......
......@@ -16,6 +16,7 @@ public class TopicAdminServiceImpl implements TopicAdminService {
public NewTopic createTopic(StreamRecord streamRecord) {
logger.debug("Creating Topic for StreamRecord: {}", streamRecord);
return TopicBuilder.name(streamRecord.getKind())
//TODO: How to setup partitions and topics
.partitions(10)
.replicas(3)
.build();
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment