我想在 CSharp 中为 kafka 编写一个自定义序列化程序。我搜索了很多,但没有找到关于如何用 dotnet 语言为 kafka 编写自定义序列化程序的好参考。
关于如何编写一个以及如何做到这一点的任何想法?
.net c# serialization apache-kafka customserializer
如果到下一个计划时前一个尚未完成,我有一个案例可以跳过 DAG 的整个运行。有没有办法做到这一点?
想象一下,DAG 需要每小时运行一次,并且计划在上午 9 点运行在上午 10 点时尚未完成,在我的情况下,我想完全跳过上午 10 点运行。
directed-acyclic-graphs airflow
.net ×1
airflow ×1
apache-kafka ×1
c# ×1
customserializer ×1
directed-acyclic-graphs ×1
serialization ×1