Feat/kafka - Githubissues

xmidt-org / caduceus

The Xmidt server for delivering events written in Go.

Apache License 2.0

16 stars 19 forks source link

Feat/kafka #538

Closed maurafortino closed 1 week ago

maurafortino commented 2 weeks ago

What's Included:

added select case for ancla.RegistryV2 for NewSink - only for Kafka
added in basic configuration for a Kafka producer

TODO:

figure out what configurations will be needed for Kafka producer
edit Kafka send function
kafka headers and adding arrays correctly