Failing to specify a value for database.server.name results in the generation of a default value constructed from the host name, port and database name in PostgresConnectorConfig.java . Unfortunately this default value includes the "/" character, which is illegal within Kafka topic names, as evidenced by Kafka's Topic.scala. This results in an error when trying to use the generated topic name, due to validation failure for the name.