V návaznosti na to (omlouvám se, měl jiný uživatel): Kafka Klíč přístup na Vniknutí Python Flink Stavové funkce
Náš případ použití je, že jsme využít Kafka záhlaví jako prostředek sledování a rodu, stejně jako metadata. Při pohledu na tento: https://github.com/apache/flink-statefun/blob/master/statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressDeserializer.java#L45-L61 vypadá To, že pomocí standardní deserializer, záhlaví jsou vynechány.
Účinně, co chci, je způsob, jak aplikovat své vlastní deserializer, která vrátí zprávu obsahující tuto a jakékoliv další metadata ze záznamu. Chtěl bych přidat něco jako UniversalKafkaIngress tak, že bych mohl nakonfigurovat pomocí vzdáleného modulu.
Při pohledu na kód, vidím, že jsem se mohl zaregistrovat nový ExtensionModule, a nahradit deserializer (a vytvořit vlastní druh). Je to doporučeno? Pokud ano - jsou tam nějaké dokumenty na tohle (pokud ne, jak bych mohl nastavit statefun, aby si to vyzvednout)?
Nebo je tam jiný preferovaný způsob?
Ještě jednou díky...