小编Sas*_*adi的帖子

使用 CSharp 在 Kafka 中自定义序列化

我想在 CSharp 中为 kafka 编写一个自定义序列化程序。我搜索了很多,但没有找到关于如何用 dotnet 语言为 kafka 编写自定义序列化程序的好参考。

关于如何编写一个以及如何做到这一点的任何想法?

.net c# serialization apache-kafka customserializer

2
推荐指数
1
解决办法
1425
查看次数

如果在下一个计划时之前的运行尚未完成,如何跳过 DAG 的下一个计划?

如果到下一个计划时前一个尚未完成,我有一个案例可以跳过 DAG 的整个运行。有没有办法做到这一点?

想象一下,DAG 需要每小时运行一次,并且计划在上午 9 点运行在上午 10 点时尚未完成,在我的情况下,我想完全跳过上午 10 点运行。

directed-acyclic-graphs airflow

2
推荐指数
1
解决办法
4479
查看次数