Kafka message filtering based on a field from message

Kafka Connect
1

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": {

			"name":"abcd",
			"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.

2

Hi @prashant4145 ,

You can do this using Single Message Transform:

3

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

4

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