Merge pull request #2 from fetch-rewards/remove-table-hardcode

removed hardcode
fetch-rewards · Jun 10, 2022 · f3dcc60 · f3dcc60
2 parents 5817ebf + bf5f430
commit f3dcc60
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/source/src/main/java/com/trustpilot/connector/dynamodb/utils/RecordConverter.java b/source/src/main/java/com/trustpilot/connector/dynamodb/utils/RecordConverter.java
@@ -45,7 +45,7 @@ public class RecordConverter {
 
     public RecordConverter(TableDescription tableDesc, String topicNamePrefix) {
         this.tableDesc = tableDesc;
-        this.topic_name = topicNamePrefix + tableDesc.getTableName();
+        this.topic_name = topicNamePrefix;
 
         valueSchema = SchemaBuilder.struct()
                                    .name(SchemaNameAdjuster.DEFAULT.adjust( "com.trustpilot.connector.dynamodb.envelope"))