diff --git a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/signal/KafkaSignalThread.java b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/signal/KafkaSignalThread.java index 11181fe9a09..0b121b711c8 100644 --- a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/signal/KafkaSignalThread.java +++ b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/signal/KafkaSignalThread.java @@ -81,7 +81,7 @@ public class KafkaSignalThread { .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)