Kafka message filtering based on a field from message

Hello there,

I am having a data into one topic and I have Sink Connector through which all messages get streamed to an application in the ecosystem. I need to filter and send messages only when one field is greater than 50. Message is in JSON format. For eg.

	"value": {
		"value1": {

			"score": 133

if the score is greater than 50 then only I want to stream this message into sink connector.

@rmoff looking forward for your help.

Thanks in advance.

Hi @prashant4145 ,

You can do this using Single Message Transform:

Thanks alot @rmoff for the help. It will really help alot.

This topic was automatically closed 7 days after the last reply. New replies are no longer allowed.