DBZ-5045 Remove deprecated MAX_COPY_THREADS
This commit is contained in:
parent
0d6bfec265
commit
64ef812cc9
@ -284,17 +284,6 @@ public boolean isFullUpdate() {
|
|||||||
.withValidation(Field::isBoolean)
|
.withValidation(Field::isBoolean)
|
||||||
.withDescription("Whether invalid host names are allowed when using SSL. If true the connection will not prevent man-in-the-middle attacks");
|
.withDescription("Whether invalid host names are allowed when using SSL. If true the connection will not prevent man-in-the-middle attacks");
|
||||||
|
|
||||||
@Deprecated
|
|
||||||
public static final Field MAX_COPY_THREADS = Field.create("initial.sync.max.threads")
|
|
||||||
.withDisplayName("Maximum number of threads for initial sync")
|
|
||||||
.withType(Type.INT)
|
|
||||||
.withWidth(Width.SHORT)
|
|
||||||
.withImportance(Importance.MEDIUM)
|
|
||||||
.withDefault(1)
|
|
||||||
.withValidation(Field::isPositiveInteger)
|
|
||||||
.withDescription("(Deprecated) Maximum number of threads used to perform an initial sync of the collections in a replica set. "
|
|
||||||
+ "Defaults to 1.");
|
|
||||||
|
|
||||||
public static final Field CONNECT_BACKOFF_INITIAL_DELAY_MS = Field.create("connect.backoff.initial.delay.ms")
|
public static final Field CONNECT_BACKOFF_INITIAL_DELAY_MS = Field.create("connect.backoff.initial.delay.ms")
|
||||||
.withDisplayName("Initial delay before reconnection (ms)")
|
.withDisplayName("Initial delay before reconnection (ms)")
|
||||||
.withType(Type.LONG)
|
.withType(Type.LONG)
|
||||||
@ -530,7 +519,6 @@ public boolean isFullUpdate() {
|
|||||||
FIELD_RENAMES,
|
FIELD_RENAMES,
|
||||||
SNAPSHOT_FILTER_QUERY_BY_COLLECTION)
|
SNAPSHOT_FILTER_QUERY_BY_COLLECTION)
|
||||||
.connector(
|
.connector(
|
||||||
MAX_COPY_THREADS,
|
|
||||||
SNAPSHOT_MODE,
|
SNAPSHOT_MODE,
|
||||||
CAPTURE_MODE,
|
CAPTURE_MODE,
|
||||||
SCHEMA_NAME_ADJUSTMENT_MODE)
|
SCHEMA_NAME_ADJUSTMENT_MODE)
|
||||||
@ -700,16 +688,8 @@ public String getConnectorName() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private static int resolveSnapshotMaxThreads(Configuration config) {
|
private static int resolveSnapshotMaxThreads(Configuration config) {
|
||||||
if (config.hasKey(SNAPSHOT_MAX_THREADS.name())) {
|
|
||||||
return config.getInteger(SNAPSHOT_MAX_THREADS);
|
return config.getInteger(SNAPSHOT_MAX_THREADS);
|
||||||
}
|
}
|
||||||
else {
|
|
||||||
if (config.hasKey(MAX_COPY_THREADS.name())) {
|
|
||||||
LOGGER.warn("The option '{}' is deprecated. Use '{}' instead.", MAX_FAILED_CONNECTIONS.name(), SNAPSHOT_MAX_THREADS.name());
|
|
||||||
}
|
|
||||||
return config.getInteger(MAX_COPY_THREADS);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Optional<String[]> parseSignallingMessage(Struct value) {
|
public Optional<String[]> parseSignallingMessage(Struct value) {
|
||||||
|
@ -22,6 +22,6 @@ public ConnectorDescriptor getConnectorDescriptor() {
|
|||||||
@Override
|
@Override
|
||||||
public Field.Set getConnectorFields() {
|
public Field.Set getConnectorFields() {
|
||||||
return MongoDbConnectorConfig.ALL_FIELDS
|
return MongoDbConnectorConfig.ALL_FIELDS
|
||||||
.filtered(f -> f != MongoDbConnectorConfig.POLL_INTERVAL_SEC && f != MongoDbConnectorConfig.MAX_COPY_THREADS);
|
.filtered(f -> f != MongoDbConnectorConfig.POLL_INTERVAL_SEC);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user