@Test
public void initialize() throws SQLException {

    JdbcConsumerManager consumer = createJdbcConsumerManager();
    // Assert connection exists
    assertFalse(consumer.connection.isClosed());
    // Assert that the Table exists
    ResultSet resultSet;
    try (Statement statement = consumer.connection.createStatement()) {
        resultSet = statement.executeQuery("SELECT * FROM CONSUMER");
    }
    // Not null means the query did not fail
    assertNotNull(resultSet);
    consumer.close();
}