test_class.declarator: DEFAULT_TOPIC = "events"
test_class.modifier: private static final
test_class.original_string: private static final String DEFAULT_TOPIC = "events";
test_class.type: String
test_class.var_name: DEFAULT_TOPIC
test_class.file: services/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaPublishTargetTest.java
test_class.identifier: KafkaPublishTargetTest
test_case.body: @Test(expected = NullPointerException.class)
      public void testNull() {
          KafkaPublishTarget.fromTargetAddress(null);
      }
test_case.class_method_signature: KafkaPublishTargetTest.testNull()
test_case.full_signature: @Test(expected = NullPointerException.class) public void testNull()
test_case.identifier: testNull
test_case.invocations: fromTargetAddress
test_case.modifiers: @Test(expected = NullPointerException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testNull()
focal_class.declarator: KEY_SEPARATOR = "/"
focal_class.modifier: static final
focal_class.original_string: static final String KEY_SEPARATOR = "/";
focal_class.type: String
focal_class.var_name: KEY_SEPARATOR
focal_class.declarator: PARTITION_SEPARATOR = "#"
focal_class.modifier: static final
focal_class.original_string: static final String PARTITION_SEPARATOR = "#";
focal_class.type: String
focal_class.var_name: PARTITION_SEPARATOR
focal_class.declarator: topic
focal_class.modifier: private final
focal_class.original_string: private final String topic;
focal_class.type: String
focal_class.var_name: topic
focal_class.declarator: key
focal_class.modifier: private final
focal_class.original_string: private final String key;
focal_class.type: String
focal_class.var_name: key
focal_class.declarator: partition
focal_class.modifier: private final
focal_class.original_string: private final Integer partition;
focal_class.type: Integer
focal_class.var_name: partition
focal_class.file: services/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaPublishTarget.java
focal_class.identifier: KafkaPublishTarget
focal_class.interfaces: implements PublishTarget
focal_class.class_method_signature: KafkaPublishTarget.KafkaPublishTarget(final String topic, @Nullable final String key, @Nullable final Integer partition)
focal_class.full_signature: private  KafkaPublishTarget(final String topic, @Nullable final String key, @Nullable final Integer partition)
focal_class.identifier: KafkaPublishTarget
focal_class.modifiers: private
focal_class.parameters: (final String topic, @Nullable final String key, @Nullable final Integer partition)
focal_class.signature:  KafkaPublishTarget(final String topic, @Nullable final String key, @Nullable final Integer partition)
focal_class.class_method_signature: KafkaPublishTarget.fromTargetAddress(final String targetAddress)
focal_class.full_signature: static KafkaPublishTarget fromTargetAddress(final String targetAddress)
focal_class.identifier: fromTargetAddress
focal_class.modifiers: static
focal_class.parameters: (final String targetAddress)
focal_class.return: KafkaPublishTarget
focal_class.signature: KafkaPublishTarget fromTargetAddress(final String targetAddress)
focal_class.class_method_signature: KafkaPublishTarget.containsKey(final String targetAddress)
focal_class.full_signature: static boolean containsKey(final String targetAddress)
focal_class.identifier: containsKey
focal_class.modifiers: static
focal_class.parameters: (final String targetAddress)
focal_class.return: boolean
focal_class.signature: boolean containsKey(final String targetAddress)
focal_class.class_method_signature: KafkaPublishTarget.fromTargetAddressWithKey(final String targetAddress)
focal_class.full_signature: private static KafkaPublishTarget fromTargetAddressWithKey(final String targetAddress)
focal_class.identifier: fromTargetAddressWithKey
focal_class.modifiers: private static
focal_class.parameters: (final String targetAddress)
focal_class.return: KafkaPublishTarget
focal_class.signature: KafkaPublishTarget fromTargetAddressWithKey(final String targetAddress)
focal_class.class_method_signature: KafkaPublishTarget.validateKey(final String key)
focal_class.full_signature: @Nullable private static String validateKey(final String key)
focal_class.identifier: validateKey
focal_class.modifiers: @Nullable private static
focal_class.parameters: (final String key)
focal_class.return: String
focal_class.signature: String validateKey(final String key)
focal_class.class_method_signature: KafkaPublishTarget.containsPartition(final String targetAddress)
focal_class.full_signature: static boolean containsPartition(final String targetAddress)
focal_class.identifier: containsPartition
focal_class.modifiers: static
focal_class.parameters: (final String targetAddress)
focal_class.return: boolean
focal_class.signature: boolean containsPartition(final String targetAddress)
focal_class.class_method_signature: KafkaPublishTarget.fromTargetAddressWithPartition(final String targetAddress)
focal_class.full_signature: private static KafkaPublishTarget fromTargetAddressWithPartition(final String targetAddress)
focal_class.identifier: fromTargetAddressWithPartition
focal_class.modifiers: private static
focal_class.parameters: (final String targetAddress)
focal_class.return: KafkaPublishTarget
focal_class.signature: KafkaPublishTarget fromTargetAddressWithPartition(final String targetAddress)
focal_class.class_method_signature: KafkaPublishTarget.validatePartition(final String partitionString)
focal_class.full_signature: @Nullable private static Integer validatePartition(final String partitionString)
focal_class.identifier: validatePartition
focal_class.modifiers: @Nullable private static
focal_class.parameters: (final String partitionString)
focal_class.return: Integer
focal_class.signature: Integer validatePartition(final String partitionString)
focal_class.class_method_signature: KafkaPublishTarget.fromTargetAddressWithOnlyTopic(final String targetAddress)
focal_class.full_signature: private static KafkaPublishTarget fromTargetAddressWithOnlyTopic(final String targetAddress)
focal_class.identifier: fromTargetAddressWithOnlyTopic
focal_class.modifiers: private static
focal_class.parameters: (final String targetAddress)
focal_class.return: KafkaPublishTarget
focal_class.signature: KafkaPublishTarget fromTargetAddressWithOnlyTopic(final String targetAddress)
focal_class.class_method_signature: KafkaPublishTarget.validateTopic(final String topic)
focal_class.full_signature: private static String validateTopic(final String topic)
focal_class.identifier: validateTopic
focal_class.modifiers: private static
focal_class.parameters: (final String topic)
focal_class.return: String
focal_class.signature: String validateTopic(final String topic)
focal_class.class_method_signature: KafkaPublishTarget.parsePartitionOrThrow(final String partitionString)
focal_class.full_signature: private static Integer parsePartitionOrThrow(final String partitionString)
focal_class.identifier: parsePartitionOrThrow
focal_class.modifiers: private static
focal_class.parameters: (final String partitionString)
focal_class.return: Integer
focal_class.signature: Integer parsePartitionOrThrow(final String partitionString)
focal_class.class_method_signature: KafkaPublishTarget.getTopic()
focal_class.full_signature:  String getTopic()
focal_class.identifier: getTopic
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getTopic()
focal_class.class_method_signature: KafkaPublishTarget.getKey()
focal_class.full_signature:  Optional<String> getKey()
focal_class.identifier: getKey
focal_class.parameters: ()
focal_class.return: Optional<String>
focal_class.signature: Optional<String> getKey()
focal_class.class_method_signature: KafkaPublishTarget.getPartition()
focal_class.full_signature:  Optional<Integer> getPartition()
focal_class.identifier: getPartition
focal_class.parameters: ()
focal_class.return: Optional<Integer>
focal_class.signature: Optional<Integer> getPartition()
focal_class.class_method_signature: KafkaPublishTarget.equals(@Nullable final Object o)
focal_class.full_signature: @Override public boolean equals(@Nullable final Object o)
focal_class.identifier: equals
focal_class.modifiers: @Override public
focal_class.parameters: (@Nullable final Object o)
focal_class.return: boolean
focal_class.signature: boolean equals(@Nullable final Object o)
focal_class.class_method_signature: KafkaPublishTarget.hashCode()
focal_class.full_signature: @Override public int hashCode()
focal_class.identifier: hashCode
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int hashCode()
focal_class.class_method_signature: KafkaPublishTarget.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_method.body: static KafkaPublishTarget fromTargetAddress(final String targetAddress) {
          if (containsKey(targetAddress)) {
              return fromTargetAddressWithKey(targetAddress);
          } else if (containsPartition(targetAddress)) {
              return fromTargetAddressWithPartition(targetAddress);
          }
  
          return fromTargetAddressWithOnlyTopic(targetAddress);
      }
focal_method.class_method_signature: KafkaPublishTarget.fromTargetAddress(final String targetAddress)
focal_method.full_signature: static KafkaPublishTarget fromTargetAddress(final String targetAddress)
focal_method.identifier: fromTargetAddress
focal_method.invocations: containsKey fromTargetAddressWithKey containsPartition fromTargetAddressWithPartition fromTargetAddressWithOnlyTopic
focal_method.modifiers: static
focal_method.parameters: (final String targetAddress)
focal_method.return: KafkaPublishTarget
focal_method.signature: KafkaPublishTarget fromTargetAddress(final String targetAddress)