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