DBZ-3141 Changes after review
This commit is contained in:
parent
f23421920b
commit
c8eec4995b
@ -415,7 +415,7 @@ public static BinaryHandlingMode parse(String value, String defaultValue) {
|
||||
.withType(Type.STRING)
|
||||
.withWidth(Width.MEDIUM)
|
||||
.withImportance(Importance.MEDIUM)
|
||||
.withDescription("The name of the data collection that is used to send signlas/commands to Debezium. Signaling is disabled when not set.");
|
||||
.withDescription("The name of the data collection that is used to send signals/commands to Debezium. Signaling is disabled when not set.");
|
||||
|
||||
protected static final ConfigDefinition CONFIG_DEFINITION = ConfigDefinition.editor()
|
||||
.connector(
|
||||
|
@ -15,6 +15,7 @@
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import io.debezium.annotation.NotThreadSafe;
|
||||
import io.debezium.config.CommonConnectorConfig;
|
||||
import io.debezium.data.Envelope;
|
||||
import io.debezium.document.Document;
|
||||
@ -38,6 +39,7 @@
|
||||
* @author Jiri Pechanec
|
||||
*
|
||||
*/
|
||||
@NotThreadSafe
|
||||
public class Signal {
|
||||
|
||||
@FunctionalInterface
|
||||
|
Loading…
Reference in New Issue
Block a user