kafka的SMT在提取JSON字段作为消息键时经常失败

您可以使用JsonPath提取JSON字段并将其设置为消息键。以下是一个使用JsonPath提取JSON字段的示例：

transforms=ExtractField
transforms.ExtractField.type=org.apache.kafka.connect.transforms.ExtractField$Key
transforms.ExtractField.field=json.field.to.extract

# 设置JsonPath表达式
transforms.ExtractField.json.path=$.fieldName

# 将提取到的值设置为消息键
transforms.ExtractField.key.field=fieldName

这里，JsonPath表达式设置为“$.fieldName”，这将提取JSON对象中的“fieldName”字段。然后，此字段可以设置为消息键。请确保您已将kafka connect的“org.apache.kafka:kafka-connect-json”库添加到您的应用程序的classpath中。