create public class KafkaConsumer to replace public class DmaapConsumer create public class KafkaProducer implements IMessageQueueHandlerProducer to replace public class DmaapProducer implements IMessageQueueHandlerProducer create public class KafkaClientFactory to use in KafkaConsumer,KafkaProducer replace usage of DmaapProducer with KafkaProducer in org.openecomp.sdc.be.facade.operations.CatalogOperation org.openecomp.sdc.be.facade.operations.UserOperation create public class KafkaProducerHealth to replace public class DmaapProducerHealth create public class KafkaHealth to replace public class DmaapHealth add or replace @Resource private DmaapProducerHealth dmaapProducerHealth; @Resource private DmaapHealth dmaapHealth; with @Resource private KafkaProducerHealth kafkaProducerHealth; @Resource private KafkaHealth kafkaHealth; in org.openecomp.sdc.be.components.health.HealthCheckBusinessLogic create public interface IKafkaAuditNotificationData public interface IKafkaNotificationData public class KafkaNotificationDataImpl implements IKafkaNotificationData, IKafkaAuditNotificationData to replace public interface IDmaapAuditNotificationData public interface IDmaapNotificationData public class DmaapNotificationDataImpl implements IDmaapNotificationData, IDmaapAuditNotificationData create public class KafkaConsumerConfiguration public class KafkaProducerConfiguration to replace public class DmaapConsumerConfiguration public class DmaapProducerConfiguration replace private DmaapConsumerConfiguration dmaapConsumerConfiguration; private DmaapProducerConfiguration dmaapProducerConfiguration; with private KafkaConsumerConfiguration kafkaConsumerConfiguration; private KafkaProducerConfiguration kafkaProducerConfiguration; in org.openecomp.sdc.be.config.Configuration replace IDmaapAuditNotificationData,IDmaapNotificationData,DmaapNotificationDataImpl,DmaapConsumer,DmaapConsumerConfiguration,DmaapProducerConfiguration with IKafkaAuditNotificationData,IKafkaNotificationData,KafkaNotificationDataImpl,KafkaConsumer,KafkaConsumerConfiguration,KafkaProducerConfiguration in org.openecomp.sdc.be.components.distribution.engine.EnvironmentsEngine remove com.att.aft dme2 org.onap.dmaap.messagerouter.dmaapclient dmaapClient