Hi @joedyson,

A filter can be added in event handler for that particular entity (Party) to filter via meta event type (insert/update), then you should create a processor which is an event plan publisher; in the plan the logic should be developed so that it can write to Kafka Topic that has already been configured.

Hope it helps.

com.ataccama.nme.core.NmeException: java.lang.NullPointerException
	at com.ataccama.nme.engine.event.handler.SimpleEventProcessor$NmeSimpleEventProcRuntime.publish(SimpleEventProcessor.java:66)
	at com.ataccama.nme.engine.event.handler.NmeEventPublisherBase$Runner.mainLoop(NmeEventPublisherBase.java:210)
	at com.ataccama.nme.engine.event.handler.NmeEventPublisherBase$Runner.run(NmeEventPublisherBase.java:172)
	at java.base/java.lang.Thread.run(Unknown Source)
Caused by: java.lang.NullPointerException
	at com.ataccama.dqc.streaming.io.writer.KafkaWriter.validate(KafkaWriter.java:130)
	at com.ataccama.dqc.model.validation.ValidationUtils.validateRecursiveInternal(ValidationUtils.java:158)
	at com.ataccama.dqc.model.validation.ValidationUtils.validateRecursive(ValidationUtils.java:127)
	at com.ataccama.dqc.tasks.common.config.ValidatingStepConfigBase.validateElement(ValidatingStepConfigBase.java:39)
	at com.ataccama.dqc.model.internal.refs.NormalModeStrategy.validateElement(NormalModeStrategy.java:61)
	at com.ataccama.dqc.model.internal.refs.StepReference.validateElement(StepReference.java:81)
	at com.ataccama.dqc.model.internal.modelimpl.DefaultModelImpl.validate(DefaultModelImpl.java:211)
	at com.ataccama.dqc.model.internal.modelimpl.DefaultModelImpl.validate(DefaultModelImpl.java:199)
	at com.ataccama.nme.internal.dqc.PlanExecutor.createRunner(PlanExecutor.java:127)
	at com.ataccama.nme.internal.dqc.PlanExecutor.<init>(PlanExecutor.java:83)
	at com.ataccama.nme.internal.dqc.OnDemandPlanExecutor.createExecutor(OnDemandPlanExecutor.java:106)
	at com.ataccama.nme.dqc.event.EventPlanPublisher$TheRuntime$TheSession.<init>(EventPlanPublisher.java:200)
	at com.ataccama.nme.dqc.event.EventPlanPublisher$TheRuntime$TheSession.<init>(EventPlanPublisher.java:194)
	at com.ataccama.nme.dqc.event.EventPlanPublisher$TheRuntime.createSession(EventPlanPublisher.java:191)
	at com.ataccama.nme.engine.event.handler.SimpleEventProcessor$NmeSimpleEventProcRuntime.publishInner(SimpleEventProcessor.java:77)
	at com.ataccama.nme.engine.event.handler.SimpleEventProcessor$NmeSimpleEventProcRuntime.publish(SimpleEventProcessor.java:64)
	... 3 more

I have problem with ataccama publish message in the kafka

Hi @joedyson ,

please find my answer here: 

Thank you,

Adél