可以丢弃Kafka CONNECT值转换器中的记录吗?

kgsdhlau  于 2022-09-21  发布在  Kafka
关注(0)|答案(1)|浏览(191)

我正在尝试生成一个仅处理特定主题中的特定消息的定制值转换器。到目前为止,我有一种筛选器转换来丢弃这些消息,但我想避免甚至处理它们,所以实际上是在值转换器本身上丢弃它们。我试图只返回一个空值,但失败了,所以我想知道是否有方法可以做到这一点,如果有的话,有什么已知的例子吗?如果不是,我可以只返回一个空的SchemaAndValue,但我想知道是否有更好的方法,因为这种方法我仍然需要返回一些东西,然后用转换过滤掉它们。

xxb16uws

xxb16uws1#

过滤是一种处理,因此转换是完成此操作的正确方法。

如果您的意思是要防止反序列化,并且您正在使用一些定制的二进制格式并根据其内容进行过滤,那么使用记录头可能是排除事件的更好方法。然后使用ByteArrayConverter作为传递

相关问题