问道2022

版本选择 0.7版本:只有基础消息队列功能，无副本；打死也不使用 0.8版本:增加了副本机制，新的producer API；建议使用0.8.2.2版本；不建议使用0.8.2....

it_zzy

Flink实现Kafka到Mysql的Exactly-Once 背景 最近项目中使用Flink消费kafka消息，并将消费的消息存储到mysql中，看似一个很简单的需求，在网...

breeze_lsw

背景 每个开发者都想了解自己任务运行时的状态，便于调优及排错，Spark 提供的 webui 已经提供了很多信息，用户可以从上面了解到任务的 shuffle，任务运行等信息，...