Skip to content

Commit eb752bd

Browse files
More logging
1 parent b799fa5 commit eb752bd

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

kafka/src/main/java/com/netflix/conductor/kafka/status/events/services/KafkaEventServiceImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ public KafkaEventServiceImpl(KafkaProperties kafkaProperties) {
6969

7070
@Override
7171
public <V> void produce(String key, V message, String topic) throws Exception {
72-
72+
LOGGER.info("Sending message to Kafka");
7373
KafkaProducer<String, Object> producer = getKafkaProducer(kafkaProperties);
7474
final ProducerRecord<String, Object> record = new ProducerRecord<>(topic, key, message);
7575

0 commit comments

Comments
 (0)