Configuration config = Configuration.create()
.with("connector.class", "io.debezium.connector.postgresql.PostgresConnector")
.with("offset.storage", "org.apache.kafka.connect.storage.KafkaOffsetBackingStore")
.with(DistributedConfig.OFFSET_STORAGE_TOPIC_CONFIG, "connect-offsets")
.with(DistributedConfig.OFFSET_STORAGE_PARTITIONS_CONFIG, 1)
.with(DistributedConfig.OFFSET_STORAGE_REPLICATION_FACTOR_CONFIG, 1)
.with("bootstrap.servers", "localhost:9092")
.with("group.id", "test-java-consumer")
.with("name", "foo")
.with("database.hostname", "localhost")
.with("database.port", 5432)
.with("database.dbname", "postgres")
.with("database.user", "notxcain")
.with("database.password", "pwd")
.with("database.server.name", "java.baz")
.build();