Required key in KafkaTopic

[mathieux51]

Is there anyway that kind: KafkaTopic could enforce the use of a Kafka key? Using kaf CLI I can publish something like:

echo '{"message": "foo"}' | kaf produce foo
echo '{"message": "foo"}' | kaf produce foo --key my-key

I would like that first one to tail somehow, possible?

[scholzj]

The KafkaTopic CR just creates the topic inside Kafka. But sending / receiving messages is fully in Kafka's responsibility. And I do not think Kafka supports anything like that.

[mathieux51]

Ok. Thank you 🙏