卡夫卡連接（單個消息變換）行過濾

Question

我讀到卡夫卡連接在卡夫卡0.10.2.1 ​​

引入變換我注意到，所有的變換是基於列的變換。 我有一個用例，我需要基於值的過濾。例如：

考慮一羣人的以下數據集：

{"firstName": "FirstName1", "lastName": "LastName1", "age": 30} 
{"firstName": "FirstName2", "lastName": "LastName2", "age": 30} 
{"firstName": "FirstName3", "lastName": "LastName1", "age": 60} 
{"firstName": "FirstName4", "lastName": "LastName2", "age": 60} 

我希望我的員工來過濾所有那些記錄lastName的是LastName2

是否有可能使用卡夫卡連接或我需要爲這個用例編寫一個單獨的程序。

感謝

Answer 1

沒有理由，你爲什麼不能用單個消息來變換解決這個問題 - 但你需要編寫一個自定義的，因爲你描述無法通過目前出貨變換。

這是這裏的有用談話何時使用，並且不使用，的SMT：Kafka Summit New York 2017 : Single Message Transformations Are Not the Transformations You’re Looking For (Ewen Cheslack-Postava, Confluent)