diff options
| author |   efiacor <fiachra.corcoran@est.tech> | 2023-03-29 12:52:11 +0100 |
|---|---|---|
| committer | efiacor <fiachra.corcoran@est.tech> | 2023-04-03 09:48:00 +0100 |
| commit | c3386ebc4fd444e810d8739f7ddd78765d36c631 (patch) | |
| tree | eee955a759be4cf85d6052b56f1ac83ae75c851b /kafkaClient/src | |
| parent | 2d3181aa8e21a6f4b31565958cf2cb35bc836dff (diff) | |
Signed-off-by: efiacor <fiachra.corcoran@est.tech>
Change-Id: Iaa3c2ff9b60aa5a691242deec82911a700222d9a
Issue-ID: DMAAP-1847
Diffstat (limited to 'kafkaClient/src')
| -rw-r--r-- | kafkaClient/src/main/java/org/onap/dmaap/kafka/OnapKafkaClient.java | 2 | ||||
| -rw-r--r-- | kafkaClient/src/main/java/org/onap/dmaap/kafka/OnapKafkaConsumer.java | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/kafkaClient/src/main/java/org/onap/dmaap/kafka/OnapKafkaClient.java b/kafkaClient/src/main/java/org/onap/dmaap/kafka/OnapKafkaClient.java index 7986869..71fcac0 100644 --- a/kafkaClient/src/main/java/org/onap/dmaap/kafka/OnapKafkaClient.java +++ b/kafkaClient/src/main/java/org/onap/dmaap/kafka/OnapKafkaClient.java @@ -70,7 +70,7 @@ public class OnapKafkaClient { * Publish data to a given topic * @param topicName The topic to which the message should be published * @param data The data to publish to the topic specified - * @return + * @return The RecordMetedata of the request */ public RecordMetadata publishToTopic(String topicName, String data) { // Should we check the data size and chunk it if necessary? Do we need to? diff --git a/kafkaClient/src/main/java/org/onap/dmaap/kafka/OnapKafkaConsumer.java b/kafkaClient/src/main/java/org/onap/dmaap/kafka/OnapKafkaConsumer.java index e08e229..c6e312d 100644 --- a/kafkaClient/src/main/java/org/onap/dmaap/kafka/OnapKafkaConsumer.java +++ b/kafkaClient/src/main/java/org/onap/dmaap/kafka/OnapKafkaConsumer.java @@ -56,7 +56,7 @@ public class OnapKafkaConsumer { Properties props = new Properties(); props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer"); props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer"); - props.put(ConsumerConfig.CLIENT_ID_CONFIG, configuration.getConsumerID() + "-consumer-" + UUID.randomUUID()); + props.put(ConsumerConfig.CLIENT_ID_CONFIG, configuration.getConsumerID()); props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, configuration.getKafkaSecurityProtocolConfig()); props.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, configuration.getKafkaBootstrapServers()); props.put(SaslConfigs.SASL_JAAS_CONFIG, configuration.getKafkaSaslJaasConfig()); |