io.debezium.config.Field.group()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(7.7k)|赞(0)|评价(0)|浏览(224)

本文整理了Java中io.debezium.config.Field.group()方法的一些代码示例，展示了Field.group()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Field.group()方法的具体详情如下：
包路径：io.debezium.config.Field
类名称：Field
方法名：group

Field.group介绍

[英]Add this field to the given configuration definition.
[中]将此字段添加到给定的配置定义中。

代码示例

代码示例来源：origin: debezium/debezium

protected static ConfigDef configDef() {
  ConfigDef config = new ConfigDef();
  Field.group(config, "MongoDB", HOSTS, USER, PASSWORD, LOGICAL_NAME, CONNECT_BACKOFF_INITIAL_DELAY_MS,
        CONNECT_BACKOFF_MAX_DELAY_MS, MAX_FAILED_CONNECTIONS, AUTO_DISCOVER_MEMBERS,
        SSL_ENABLED, SSL_ALLOW_INVALID_HOSTNAMES);
  Field.group(config, "Events", DATABASE_WHITELIST, DATABASE_BLACKLIST, COLLECTION_WHITELIST, COLLECTION_BLACKLIST, FIELD_BLACKLIST, FIELD_RENAMES, CommonConnectorConfig.TOMBSTONES_ON_DELETE);
  Field.group(config, "Connector", MAX_COPY_THREADS, CommonConnectorConfig.MAX_QUEUE_SIZE,
      CommonConnectorConfig.MAX_BATCH_SIZE, CommonConnectorConfig.POLL_INTERVAL_MS,
      CommonConnectorConfig.SNAPSHOT_DELAY_MS);
  return config;
}

代码示例来源：origin: debezium/debezium

protected static ConfigDef configDef() {
  ConfigDef config = new ConfigDef();
  Field.group(config, "Postgres", SLOT_NAME, PLUGIN_NAME, SERVER_NAME, DATABASE_NAME, HOSTNAME, PORT,
        USER, PASSWORD, ON_CONNECT_STATEMENTS, SSL_MODE, SSL_CLIENT_CERT, SSL_CLIENT_KEY_PASSWORD, SSL_ROOT_CERT, SSL_CLIENT_KEY,
        DROP_SLOT_ON_STOP, SSL_SOCKET_FACTORY, STATUS_UPDATE_INTERVAL_MS, TCP_KEEPALIVE);
  Field.group(config, "Events", SCHEMA_WHITELIST, SCHEMA_BLACKLIST, TABLE_WHITELIST, TABLE_BLACKLIST,
        COLUMN_BLACKLIST, INCLUDE_UNKNOWN_DATATYPES, SNAPSHOT_SELECT_STATEMENT_OVERRIDES_BY_TABLE,
        CommonConnectorConfig.TOMBSTONES_ON_DELETE, Heartbeat.HEARTBEAT_INTERVAL,
        Heartbeat.HEARTBEAT_TOPICS_PREFIX);
  Field.group(config, "Connector", TOPIC_SELECTION_STRATEGY, CommonConnectorConfig.POLL_INTERVAL_MS, CommonConnectorConfig.MAX_BATCH_SIZE, CommonConnectorConfig.MAX_QUEUE_SIZE,
        CommonConnectorConfig.SNAPSHOT_DELAY_MS,
        SNAPSHOT_MODE, SNAPSHOT_LOCK_TIMEOUT_MS, TIME_PRECISION_MODE, DECIMAL_HANDLING_MODE, HSTORE_HANDLING_MODE,SCHEMA_REFRESH_MODE,ROWS_FETCH_SIZE);
  return config;
}

代码示例来源：origin: debezium/debezium

public static ConfigDef configDef() {
  ConfigDef config = new ConfigDef();
  Field.group(config, "SQL Server", LOGICAL_NAME, DATABASE_NAME, SNAPSHOT_MODE);
  Field.group(config, "History Storage", KafkaDatabaseHistory.BOOTSTRAP_SERVERS,
      KafkaDatabaseHistory.TOPIC, KafkaDatabaseHistory.RECOVERY_POLL_ATTEMPTS,
      KafkaDatabaseHistory.RECOVERY_POLL_INTERVAL_MS, HistorizedRelationalDatabaseConnectorConfig.DATABASE_HISTORY);
  Field.group(config, "Events", RelationalDatabaseConnectorConfig.TABLE_WHITELIST,
      RelationalDatabaseConnectorConfig.TABLE_BLACKLIST,
      RelationalDatabaseConnectorConfig.COLUMN_BLACKLIST,
      RelationalDatabaseConnectorConfig.TABLE_IGNORE_BUILTIN,
      Heartbeat.HEARTBEAT_INTERVAL, Heartbeat.HEARTBEAT_TOPICS_PREFIX
  );
  Field.group(config, "Connector", CommonConnectorConfig.POLL_INTERVAL_MS, CommonConnectorConfig.MAX_BATCH_SIZE,
      CommonConnectorConfig.MAX_QUEUE_SIZE, CommonConnectorConfig.SNAPSHOT_DELAY_MS);
  return config;
}

代码示例来源：origin: debezium/debezium

protected static ConfigDef configDef() {
  ConfigDef config = new ConfigDef();
  Field.group(config, "MySQL", HOSTNAME, PORT, USER, PASSWORD, ON_CONNECT_STATEMENTS, SERVER_NAME, SERVER_ID, SERVER_ID_OFFSET,
        SSL_MODE, SSL_KEYSTORE, SSL_KEYSTORE_PASSWORD, SSL_TRUSTSTORE, SSL_TRUSTSTORE_PASSWORD, JDBC_DRIVER);
  Field.group(config, "History Storage", KafkaDatabaseHistory.BOOTSTRAP_SERVERS,
        KafkaDatabaseHistory.TOPIC, KafkaDatabaseHistory.RECOVERY_POLL_ATTEMPTS,
        KafkaDatabaseHistory.RECOVERY_POLL_INTERVAL_MS, DATABASE_HISTORY,
        DatabaseHistory.SKIP_UNPARSEABLE_DDL_STATEMENTS, DatabaseHistory.DDL_FILTER,
        DatabaseHistory.STORE_ONLY_MONITORED_TABLES_DDL);
  Field.group(config, "Events", INCLUDE_SCHEMA_CHANGES, INCLUDE_SQL_QUERY, TABLES_IGNORE_BUILTIN, DATABASE_WHITELIST, TABLE_WHITELIST,
        COLUMN_BLACKLIST, TABLE_BLACKLIST, DATABASE_BLACKLIST,
        GTID_SOURCE_INCLUDES, GTID_SOURCE_EXCLUDES, GTID_SOURCE_FILTER_DML_EVENTS, GTID_NEW_CHANNEL_POSITION, BUFFER_SIZE_FOR_BINLOG_READER,
        Heartbeat.HEARTBEAT_INTERVAL, Heartbeat.HEARTBEAT_TOPICS_PREFIX, EVENT_DESERIALIZATION_FAILURE_HANDLING_MODE, INCONSISTENT_SCHEMA_HANDLING_MODE,
        CommonConnectorConfig.TOMBSTONES_ON_DELETE);
  Field.group(config, "Connector", CONNECTION_TIMEOUT_MS, KEEP_ALIVE, KEEP_ALIVE_INTERVAL_MS, CommonConnectorConfig.MAX_QUEUE_SIZE,
        CommonConnectorConfig.MAX_BATCH_SIZE, CommonConnectorConfig.POLL_INTERVAL_MS,
        SNAPSHOT_MODE, SNAPSHOT_LOCKING_MODE, SNAPSHOT_NEW_TABLES, SNAPSHOT_MINIMAL_LOCKING, TIME_PRECISION_MODE, DECIMAL_HANDLING_MODE,
        BIGINT_UNSIGNED_HANDLING_MODE, SNAPSHOT_DELAY_MS, DDL_PARSER_MODE);
  return config;
}

代码示例来源：origin: debezium/debezium

@Override
public ConfigDef config() {
  final ConfigDef config = new ConfigDef();
  Field.group(config, null, ARRAY_ENCODING);
  return config;
}

代码示例来源：origin: debezium/debezium

@Override
public ConfigDef config() {
  ConfigDef config = new ConfigDef();
  Field.group(
      config,
      null,
      TOPIC_REGEX,
      TOPIC_REPLACEMENT,
      KEY_FIELD_REGEX,
      KEY_FIELD_REPLACEMENT);
  return config;
}

代码示例来源：origin: debezium/debezium

@Override
public ConfigDef config() {
  final ConfigDef config = new ConfigDef();
  Field.group(config, null, DROP_TOMBSTONES, DROP_DELETES, HANDLE_DELETES, OPERATION_HEADER);
  return config;
}

代码示例来源：origin: io.debezium/debezium-connector-oracle

public static ConfigDef configDef() {
  ConfigDef config = new ConfigDef();
  Field.group(config, "Oracle", LOGICAL_NAME, DATABASE_NAME, PDB_NAME, XSTREAM_SERVER_NAME, SNAPSHOT_MODE);
  Field.group(config, "History Storage", KafkaDatabaseHistory.BOOTSTRAP_SERVERS,
      KafkaDatabaseHistory.TOPIC, KafkaDatabaseHistory.RECOVERY_POLL_ATTEMPTS,
      KafkaDatabaseHistory.RECOVERY_POLL_INTERVAL_MS, HistorizedRelationalDatabaseConnectorConfig.DATABASE_HISTORY);
  Field.group(config, "Events", RelationalDatabaseConnectorConfig.TABLE_WHITELIST,
      RelationalDatabaseConnectorConfig.TABLE_BLACKLIST,
      RelationalDatabaseConnectorConfig.TABLE_IGNORE_BUILTIN,
      Heartbeat.HEARTBEAT_INTERVAL, Heartbeat.HEARTBEAT_TOPICS_PREFIX
  );
  Field.group(config, "Connector", CommonConnectorConfig.POLL_INTERVAL_MS, CommonConnectorConfig.MAX_BATCH_SIZE,
      CommonConnectorConfig.MAX_QUEUE_SIZE, CommonConnectorConfig.SNAPSHOT_DELAY_MS);
  return config;
}

代码示例来源：origin: io.debezium/debezium-connector-postgres

protected static ConfigDef configDef() {
  ConfigDef config = new ConfigDef();
  Field.group(config, "Postgres", SLOT_NAME, PLUGIN_NAME, SERVER_NAME, DATABASE_NAME, HOSTNAME, PORT,
        USER, PASSWORD, ON_CONNECT_STATEMENTS, SSL_MODE, SSL_CLIENT_CERT, SSL_CLIENT_KEY_PASSWORD, SSL_ROOT_CERT, SSL_CLIENT_KEY,
        DROP_SLOT_ON_STOP, SSL_SOCKET_FACTORY, STATUS_UPDATE_INTERVAL_MS, TCP_KEEPALIVE);
  Field.group(config, "Events", SCHEMA_WHITELIST, SCHEMA_BLACKLIST, TABLE_WHITELIST, TABLE_BLACKLIST,
        COLUMN_BLACKLIST, INCLUDE_UNKNOWN_DATATYPES, SNAPSHOT_SELECT_STATEMENT_OVERRIDES_BY_TABLE,
        CommonConnectorConfig.TOMBSTONES_ON_DELETE, Heartbeat.HEARTBEAT_INTERVAL,
        Heartbeat.HEARTBEAT_TOPICS_PREFIX);
  Field.group(config, "Connector", TOPIC_SELECTION_STRATEGY, CommonConnectorConfig.POLL_INTERVAL_MS, CommonConnectorConfig.MAX_BATCH_SIZE, CommonConnectorConfig.MAX_QUEUE_SIZE,
        CommonConnectorConfig.SNAPSHOT_DELAY_MS,
        SNAPSHOT_MODE, SNAPSHOT_LOCK_TIMEOUT_MS, TIME_PRECISION_MODE, DECIMAL_HANDLING_MODE, HSTORE_HANDLING_MODE,SCHEMA_REFRESH_MODE,ROWS_FETCH_SIZE);
  return config;
}

代码示例来源：origin: io.debezium/debezium-core

@Override
public ConfigDef config() {
  ConfigDef config = new ConfigDef();
  Field.group(
      config,
      null,
      TOPIC_REGEX,
      TOPIC_REPLACEMENT,
      KEY_FIELD_REGEX,
      KEY_FIELD_REPLACEMENT);
  return config;
}

代码示例来源：origin: io.debezium/debezium-core

@Override
public ConfigDef config() {
  final ConfigDef config = new ConfigDef();
  Field.group(config, null, DROP_TOMBSTONES, DROP_DELETES, HANDLE_DELETES, OPERATION_HEADER);
  return config;
}

内容来源于网络，如有侵权，请联系作者删除！

Field

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com