- changed the log level to debug from info
Issue-ID: CPS-1990
Change-Id: I5563aaa4f95e7cd5a6df7fd9304cb0dcb0545ca3
Signed-off-by: mpriyank <priyank.maheshwari@est.tech>
groupId = "ncmp-data-operation-event-group",
containerFactory = "cloudEventConcurrentKafkaListenerContainerFactory")
public void consumeAndPublish(final ConsumerRecord<String, CloudEvent> dataOperationEventConsumerRecord) {
- log.info("Consuming event payload {} ...", dataOperationEventConsumerRecord.value());
+ log.debug("Consuming event payload {} ...", dataOperationEventConsumerRecord.value());
final String eventTarget = KafkaHeaders.getParsedKafkaHeader(
dataOperationEventConsumerRecord.headers(), "ce_destination");
final String correlationId = KafkaHeaders.getParsedKafkaHeader(