I’ve tried to do my due diligence by googling / searching this slack and I’ve come up empty.Is there a way through configuration / deltastreamer to extract a custom partition key?Basically I have a datetime field in a Kafka Source that has an ISO8601 datetime….is there a way to extract a partition value out of that?I found this after some Googling, but this seems like it’d only be useful if I wanted to write my own writer application: https://github.com/apache/incubator-hudi/blob/master/hudi-spark/src/main/java/org/apache/hudi/keygen/ComplexKeyGenerator.javaAny way to do what I need through configuration of the spark job / hudi configuration? hudi-spark/src/main/java/org/apache/hudi/keygen/ComplexKeyGenerator.java <https://github.com/apache/incubator-hudi/blob/master/hudi-spark/src/main/java/org/apache/hudi/keygen/ComplexKeyGenerator.java>
-- *Allen Underwood*
smime.p7s
Description: S/MIME Cryptographic Signature
