Skip to content
This repository was archived by the owner on Sep 22, 2025. It is now read-only.

Commit bf5f430

Browse files
removed hardcode
1 parent 5817ebf commit bf5f430

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

source/src/main/java/com/trustpilot/connector/dynamodb/utils/RecordConverter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ public class RecordConverter {
4545

4646
public RecordConverter(TableDescription tableDesc, String topicNamePrefix) {
4747
this.tableDesc = tableDesc;
48-
this.topic_name = topicNamePrefix + tableDesc.getTableName();
48+
this.topic_name = topicNamePrefix;
4949

5050
valueSchema = SchemaBuilder.struct()
5151
.name(SchemaNameAdjuster.DEFAULT.adjust( "com.trustpilot.connector.dynamodb.envelope"))

0 commit comments

Comments
 (0)