Is it possible to send metadataChangeProposals via the java kafka emitter to topic

MetadataChangeEvent_v4

instead of

MetadataChangeProposal_v1

?

Hello Samantha, What are you trying to do? Sending mcps to the change event topic will not work as the consumer listening on the change event topic only knows how to process change events, not metadata change proposal events. These 2 events are different things.

okay that makes sense. We were previously using the java emitter to hit the rest endpoint with a metadataChangeProposalWrapper, but I'm now struggling to reach Kafka. I originally thought I needed to send the request to

MetadataChangeEvent_v4

, so I thought I'd see if that was the issue. Clearly not, thank you!

I think so cc @careful-pilot-86309 Have you checked the config file: https://github.com/datahub-project/datahub/blob/master/metadata-integration/java/datahub-client/src/main/java/datahub/client/kafka/KafkaEmitterConfig.java ?

I completely missed the producerConfig options. Thank you again!

@busy-airport-23391 You are right producerConfig is not showing up with builder. schemaRegistryConfig is also not

@Builder.default

but it shows up. I will dig in more and come back.

Thank you so much!

I have done changes. Fix should be out in next release.