import java.io.IOException;
import java.time.Duration;
import java.util.Properties;
import java.io.IOException;
import java.time.Duration;
import java.util.Properties;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
@Component
public class DmaapMessageConsumer implements Runnable {
private static final Logger logger = LoggerFactory.getLogger(DmaapMessageConsumer.class);
@Component
public class DmaapMessageConsumer implements Runnable {
private static final Logger logger = LoggerFactory.getLogger(DmaapMessageConsumer.class);
private boolean isDmaapConfigured() {
Properties consumerCfg = applicationConfig.getDmaapConsumerConfig();
Properties producerCfg = applicationConfig.getDmaapPublisherConfig();
private boolean isDmaapConfigured() {
Properties consumerCfg = applicationConfig.getDmaapConsumerConfig();
Properties producerCfg = applicationConfig.getDmaapPublisherConfig();