From 37b26f429cbdebd44f293da9761144c7ceb560e4 Mon Sep 17 00:00:00 2001 From: Eduardo Froes Date: Thu, 3 Mar 2022 00:21:00 -0300 Subject: [PATCH] Fixed bugin prefix process. --- README.md | 2 +- build.gradle | 4 ++-- src/main/java/br/unicamp/ctm/codelet/CodeletGRPCServer.java | 5 +++++ .../br/unicamp/ctm/memory/kafka/TopicConfigProvider.java | 2 +- 4 files changed, 9 insertions(+), 4 deletions(-) create mode 100644 src/main/java/br/unicamp/ctm/codelet/CodeletGRPCServer.java diff --git a/README.md b/README.md index 2339b15..e68975c 100755 --- a/README.md +++ b/README.md @@ -1,3 +1,3 @@ # CTM -Cognitive System Toolkit for Microservice. +Cognitive System Toolkit for Microservices. diff --git a/build.gradle b/build.gradle index 76bc88c..abdfa68 100755 --- a/build.gradle +++ b/build.gradle @@ -5,7 +5,7 @@ plugins { } group 'com.github.CST-Group' -version '0.1.3' +version '0.1.4' sourceCompatibility = 1.8 targetCompatibility = 1.8 @@ -59,7 +59,7 @@ publishing { gpr(MavenPublication) { groupId = 'com.github.CST-Group' artifactId = 'ctm' - version = '0.1.3' + version = '0.1.4' from(components.java) } diff --git a/src/main/java/br/unicamp/ctm/codelet/CodeletGRPCServer.java b/src/main/java/br/unicamp/ctm/codelet/CodeletGRPCServer.java new file mode 100644 index 0000000..84187b0 --- /dev/null +++ b/src/main/java/br/unicamp/ctm/codelet/CodeletGRPCServer.java @@ -0,0 +1,5 @@ +package br.unicamp.ctm.codelet; + +public class CodeletGRPCServer { + +} diff --git a/src/main/java/br/unicamp/ctm/memory/kafka/TopicConfigProvider.java b/src/main/java/br/unicamp/ctm/memory/kafka/TopicConfigProvider.java index 31cc836..690d309 100755 --- a/src/main/java/br/unicamp/ctm/memory/kafka/TopicConfigProvider.java +++ b/src/main/java/br/unicamp/ctm/memory/kafka/TopicConfigProvider.java @@ -32,7 +32,7 @@ public static List generateTopicConfigsPrefix(String brokers, Strin } return foundTopics.stream().map(topic -> new - TopicConfig(topic, KDistributedMemoryBehavior.PULLED, className) + TopicConfig(topic, brokers, KDistributedMemoryBehavior.PULLED, className) ).collect(Collectors.toList()); }