有没有办法只接收来自kafka主题的特定事件类型到hdfs，并使用kafka connect hdfs连接器过滤其余类型？
kafka connect有用于处理消息的转换，但它不是用于过滤的。这通常由kafka streams或ksql完成
我们是否可以根据某个键将输入事件隔离并写入不同的分区，以便特定键的值进入特定的分区？
这个 FieldPartitioner confluent文档中提到的类可以做到这一点（警告：我相信它只处理顶级字段，而不是嵌套的json或avro记录字段）
我们可以使用schema registry中存储的键来获取特定于avro格式数据的特定键的主题中的值吗？
我不明白这个问题，但是hdfs connect在默认情况下，在写入数据时会忽略kafka消息键，所以我要说不。
kafka数据不是按键索引的，而是按键进行分区的，这意味着如果您确实使用了defaultpartitioner而不是fieldpartitioner，那么所有键都将通过kafka分区到达单个文件系统路径。只有这样，您才能进行查询，而不是通过键，而是通过分区。例如使用Spark或Hive。同样，这是默认行为-您可以使用转换，如前所述，将kafka键添加到数据中，然后您可以通过它进行查询