KafkaStreams Scala：替换 FunctionsCompatConversions

大佬教程收集整理的这篇文章主要介绍了KafkaStreams Scala：替换 FunctionsCompatConversions，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决KafkaStreams Scala：替换 FunctionsCompatConversions？

开发过程中遇到KafkaStreams Scala：替换 FunctionsCompatConversions的问题如何解决？下面主要结合日常开发的经验，给出你关于KafkaStreams Scala：替换 FunctionsCompatConversions的解决方法建议，希望对你解决KafkaStreams Scala：替换 FunctionsCompatConversions有所启发或帮助；

我在现有的一堆应用程序中使用 KafkaStreams 2.6.0、scala。

我正在设计一个方案来最大化正常运行时间/稳健性，并且在每个异常时，记录 +（丢弃或发送到死信主题）。我想在不在整个应用程序中显式添加 Try/try-catch 块的情况下执行此操作。

我有这个想法，用我自己的 FunctionsCompactConversions 替换 GuardedFunctionsCompactConversions，并在那里添加 Try-s 例如

替换

  implicit class ForeachActionFromFunction[K,V](val p: (K,V) => Unit) extends AnyVal {
    def asForeachAction: ForeachAction[K,V] = (key: K,value: V) => p(key,value)
  }

与

  implicit class ForeachActionFromFunction[K,value: V) => {
      setLogContext(value,key)
      Try(p(key,value)) match {
        case success(_) => 
        case Failure(eX) => Error(s"asForeachAction Failed $ex when handle ($key,$value)")
      }
    }
  }

或

    def asPreDicate: PreDicate[K,value)

与

    def asPreDicate: PreDicate[K,value)) match {
        case success(s) => s
        case Failure(eX) => 
          Error(s"asPreDicate Failed $ex when handle ($key,$value)")
          false
      }
    }

等等。这样 -

1. 应用程序提供的所有代码都受到保护（谓词、reducers、Serde 等），并且不能“忘记”尝试/捕获

2. 出现任何错误/异常时，可以记录手头的消息，提供有关修复内容的见解

3. 集中能够在生产等中禁用此日志记录

4. 如果进行故障排除，可以集中选择 Guarded 版本，而默认情况下使用紧凑版本

不幸的是，我没有找到正确的方法来做到这一点。我创建了 GuardedFunctionsCompactConversions 对象，但无法扩展/覆盖紧凑的对象，也无法将其导入正确的 Ktable/KStream/KGroupedStream/... 类。

这是一个常见的要求吗？我希望它是。 有没有正确的方法可以到达那里？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

大佬总结

以上是大佬教程为你收集整理的KafkaStreams Scala：替换 FunctionsCompatConversions全部内容，希望文章能够帮你解决KafkaStreams Scala：替换 FunctionsCompatConversions所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。