DBZ-6361 Remove superfluous signal prefix

debezium · Apr 19, 2023 · aa25de9 · aa25de9
1 parent 12bec97
commit aa25de9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...m-connector-mysql/src/main/java/io/debezium/connector/mysql/signal/KafkaSignalThread.java b/...m-connector-mysql/src/main/java/io/debezium/connector/mysql/signal/KafkaSignalThread.java
@@ -81,7 +81,7 @@ public class KafkaSignalThread<T extends DataCollectionId> {
             .withValidation(Field::isRequired);
 
     public static final Field SIGNAL_POLL_TIMEOUT_MS = Field.create(CONFIGURATION_FIELD_PREFIX_STRING
-            + "signal.kafka.poll.timeout.ms")
+            + "kafka.poll.timeout.ms")
             .withDisplayName("Poll timeout for kafka signals (ms)")
             .withType(ConfigDef.Type.INT)
             .withWidth(ConfigDef.Width.SHORT)