class KafkaValidator extends AbstractProtocolValidator {

    @Override
    protected void validateSource(final Source source, final DittoHeaders dittoHeaders,
            final Supplier<String> sourceDescription) {

        final String message = "Kafka connectivity currently does not provide sources.";
        throw ConnectionConfigurationInvalidException.newBuilder(message)
                .dittoHeaders(dittoHeaders)
                .build();
    }

    private  KafkaValidator();

}