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();