test_class.declarator: CONNECTION_ID = TestConstants.createRandomConnectionId()
test_class.modifier: private static final
test_class.original_string: private static final ConnectionId CONNECTION_ID = TestConstants.createRandomConnectionId();
test_class.type: ConnectionId
test_class.var_name: CONNECTION_ID
test_class.declarator: defaultSpecificConfig = new HashMap<>()
test_class.modifier: private static
test_class.original_string: private static Map<String, String> defaultSpecificConfig = new HashMap<>();
test_class.type: Map<String, String>
test_class.var_name: defaultSpecificConfig
test_class.declarator: actorSystem
test_class.modifier: private static
test_class.original_string: private static ActorSystem actorSystem;
test_class.type: ActorSystem
test_class.var_name: actorSystem
test_class.declarator: underTest
test_class.modifier: private
test_class.original_string: private KafkaValidator underTest;
test_class.type: KafkaValidator
test_class.var_name: underTest
test_class.file: services/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaValidatorTest.java
test_class.identifier: KafkaValidatorTest
test_case.body: @Test
      public void testValidBootstrapServers() {
          final DittoHeaders emptyDittoHeaders = DittoHeaders.empty();
          underTest.validate(getConnectionWithBootstrapServers("foo:123"), emptyDittoHeaders, actorSystem);
          underTest.validate(getConnectionWithBootstrapServers("foo:123,bar:456"), emptyDittoHeaders, actorSystem);
          underTest.validate(getConnectionWithBootstrapServers("foo:123, bar:456 , baz:789"), emptyDittoHeaders,
                  actorSystem);
      }
test_case.class_method_signature: KafkaValidatorTest.testValidBootstrapServers()
test_case.full_signature: @Test public void testValidBootstrapServers()
test_case.identifier: testValidBootstrapServers
test_case.invocations: empty validate getConnectionWithBootstrapServers validate getConnectionWithBootstrapServers validate getConnectionWithBootstrapServers
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testValidBootstrapServers()
focal_class.declarator: DUMMY_TOPIC = "replaced_placeholder"
focal_class.modifier: private static final
focal_class.original_string: private static final String DUMMY_TOPIC = "replaced_placeholder";
focal_class.type: String
focal_class.var_name: DUMMY_TOPIC
focal_class.declarator: DUMMY_PARTITION = "3"
focal_class.modifier: private static final
focal_class.original_string: private static final String DUMMY_PARTITION = "3";
focal_class.type: String
focal_class.var_name: DUMMY_PARTITION
focal_class.declarator: INVALID_TOPIC_FORMAT = "The provided topic ''{0}'' is not valid: {1}"
focal_class.modifier: private static final
focal_class.original_string: private static final String INVALID_TOPIC_FORMAT = "The provided topic ''{0}'' is not valid: {1}";
focal_class.type: String
focal_class.var_name: INVALID_TOPIC_FORMAT
focal_class.declarator: NOT_EMPTY_FORMAT = "The provided {0} in your target address may not be empty."
focal_class.modifier: private static final
focal_class.original_string: private static final String NOT_EMPTY_FORMAT = "The provided {0} in your target address may not be empty.";
focal_class.type: String
focal_class.var_name: NOT_EMPTY_FORMAT
focal_class.declarator: ACCEPTED_SCHEMES =
              Collections.unmodifiableList(Arrays.asList("tcp", "ssl"))
focal_class.modifier: private static final
focal_class.original_string: private static final Collection<String> ACCEPTED_SCHEMES =
              Collections.unmodifiableList(Arrays.asList("tcp", "ssl"));
focal_class.type: Collection<String>
focal_class.var_name: ACCEPTED_SCHEMES
focal_class.declarator: SECURE_SCHEMES = Collections.singletonList("ssl")
focal_class.modifier: private static final
focal_class.original_string: private static final Collection<String> SECURE_SCHEMES = Collections.singletonList("ssl");
focal_class.type: Collection<String>
focal_class.var_name: SECURE_SCHEMES
focal_class.declarator: SPECIFIC_CONFIGS = Collections.unmodifiableList(
              Arrays.asList(KafkaAuthenticationSpecificConfig.getInstance(),
                      KafkaBootstrapServerSpecificConfig.getInstance()))
focal_class.modifier: private static final
focal_class.original_string: private static final Collection<KafkaSpecificConfig> SPECIFIC_CONFIGS = Collections.unmodifiableList(
              Arrays.asList(KafkaAuthenticationSpecificConfig.getInstance(),
                      KafkaBootstrapServerSpecificConfig.getInstance()));
focal_class.type: Collection<KafkaSpecificConfig>
focal_class.var_name: SPECIFIC_CONFIGS
focal_class.declarator: INSTANCE = new KafkaValidator()
focal_class.modifier: private static final
focal_class.original_string: private static final KafkaValidator INSTANCE = new KafkaValidator();
focal_class.type: KafkaValidator
focal_class.var_name: INSTANCE
focal_class.file: services/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaValidator.java
focal_class.identifier: KafkaValidator
focal_class.class_method_signature: KafkaValidator.KafkaValidator()
focal_class.full_signature: private  KafkaValidator()
focal_class.identifier: KafkaValidator
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.signature:  KafkaValidator()
focal_class.class_method_signature: KafkaValidator.getInstance()
focal_class.full_signature: public static KafkaValidator getInstance()
focal_class.identifier: getInstance
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: KafkaValidator
focal_class.signature: KafkaValidator getInstance()
focal_class.class_method_signature: KafkaValidator.type()
focal_class.full_signature: @Override public ConnectionType type()
focal_class.identifier: type
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: ConnectionType
focal_class.signature: ConnectionType type()
focal_class.class_method_signature: KafkaValidator.validate(final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)
focal_class.full_signature: @Override public void validate(final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)
focal_class.identifier: validate
focal_class.modifiers: @Override public
focal_class.parameters: (final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)
focal_class.return: void
focal_class.signature: void validate(final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)
focal_class.class_method_signature: KafkaValidator.validateSource(final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)
focal_class.full_signature: @Override protected void validateSource(final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)
focal_class.identifier: validateSource
focal_class.modifiers: @Override protected
focal_class.parameters: (final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)
focal_class.return: void
focal_class.signature: void validateSource(final Source source, final DittoHeaders dittoHeaders,
              final Supplier<String> sourceDescription)
focal_class.class_method_signature: KafkaValidator.validateTarget(final Target target, final DittoHeaders dittoHeaders,
              final Supplier<String> targetDescription)
focal_class.full_signature: @Override protected void validateTarget(final Target target, final DittoHeaders dittoHeaders,
              final Supplier<String> targetDescription)
focal_class.identifier: validateTarget
focal_class.modifiers: @Override protected
focal_class.parameters: (final Target target, final DittoHeaders dittoHeaders,
              final Supplier<String> targetDescription)
focal_class.return: void
focal_class.signature: void validateTarget(final Target target, final DittoHeaders dittoHeaders,
              final Supplier<String> targetDescription)
focal_class.class_method_signature: KafkaValidator.validateAddress(final String address, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.full_signature: private static void validateAddress(final String address, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.identifier: validateAddress
focal_class.modifiers: private static
focal_class.parameters: (final String address, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.return: void
focal_class.signature: void validateAddress(final String address, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.class_method_signature: KafkaValidator.validateTargetAddressWithKey(final String targetAddress, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.full_signature: private static void validateTargetAddressWithKey(final String targetAddress, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.identifier: validateTargetAddressWithKey
focal_class.modifiers: private static
focal_class.parameters: (final String targetAddress, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.return: void
focal_class.signature: void validateTargetAddressWithKey(final String targetAddress, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.class_method_signature: KafkaValidator.validateTargetAddressWithPartition(final String targetAddress,
              final DittoHeaders dittoHeaders, final String placeholderReplacement)
focal_class.full_signature: private static void validateTargetAddressWithPartition(final String targetAddress,
              final DittoHeaders dittoHeaders, final String placeholderReplacement)
focal_class.identifier: validateTargetAddressWithPartition
focal_class.modifiers: private static
focal_class.parameters: (final String targetAddress,
              final DittoHeaders dittoHeaders, final String placeholderReplacement)
focal_class.return: void
focal_class.signature: void validateTargetAddressWithPartition(final String targetAddress,
              final DittoHeaders dittoHeaders, final String placeholderReplacement)
focal_class.class_method_signature: KafkaValidator.validateTopic(final String topic, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.full_signature: private static void validateTopic(final String topic, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.identifier: validateTopic
focal_class.modifiers: private static
focal_class.parameters: (final String topic, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.return: void
focal_class.signature: void validateTopic(final String topic, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.class_method_signature: KafkaValidator.validateKey(final String key, final DittoHeaders dittoHeaders)
focal_class.full_signature: private static void validateKey(final String key, final DittoHeaders dittoHeaders)
focal_class.identifier: validateKey
focal_class.modifiers: private static
focal_class.parameters: (final String key, final DittoHeaders dittoHeaders)
focal_class.return: void
focal_class.signature: void validateKey(final String key, final DittoHeaders dittoHeaders)
focal_class.class_method_signature: KafkaValidator.validatePartition(final String partition, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.full_signature: private static void validatePartition(final String partition, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.identifier: validatePartition
focal_class.modifiers: private static
focal_class.parameters: (final String partition, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.return: void
focal_class.signature: void validatePartition(final String partition, final DittoHeaders dittoHeaders,
              final String placeholderReplacement)
focal_class.class_method_signature: KafkaValidator.validateSpecificConfigs(final Connection connection, final DittoHeaders dittoHeaders)
focal_class.full_signature: private static void validateSpecificConfigs(final Connection connection, final DittoHeaders dittoHeaders)
focal_class.identifier: validateSpecificConfigs
focal_class.modifiers: private static
focal_class.parameters: (final Connection connection, final DittoHeaders dittoHeaders)
focal_class.return: void
focal_class.signature: void validateSpecificConfigs(final Connection connection, final DittoHeaders dittoHeaders)
focal_class.class_method_signature: KafkaValidator.throwEmptyException(final String type, final DittoHeaders dittoHeaders)
focal_class.full_signature: private static void throwEmptyException(final String type, final DittoHeaders dittoHeaders)
focal_class.identifier: throwEmptyException
focal_class.modifiers: private static
focal_class.parameters: (final String type, final DittoHeaders dittoHeaders)
focal_class.return: void
focal_class.signature: void throwEmptyException(final String type, final DittoHeaders dittoHeaders)
focal_class.superclass: extends AbstractProtocolValidator
focal_method.body: @Override
      public void validate(final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem) {
          validateUriScheme(connection, dittoHeaders, ACCEPTED_SCHEMES, SECURE_SCHEMES, "Kafka 2.1.1");
          validateSourceConfigs(connection, dittoHeaders);
          validateTargetConfigs(connection, dittoHeaders);
          validatePayloadMappings(connection, actorSystem, dittoHeaders);
          validateSpecificConfigs(connection, dittoHeaders);
      }
focal_method.class_method_signature: KafkaValidator.validate(final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)
focal_method.full_signature: @Override public void validate(final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)
focal_method.identifier: validate
focal_method.invocations: validateUriScheme validateSourceConfigs validateTargetConfigs validatePayloadMappings validateSpecificConfigs
focal_method.modifiers: @Override public
focal_method.parameters: (final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)
focal_method.return: void
focal_method.signature: void validate(final Connection connection, final DittoHeaders dittoHeaders, final ActorSystem actorSystem)