标签：flink-streaming

  • Apache Flink:Python流API中的Kafka连接器，“无法加载用户类” - python

    时间：2020-8-12

    我正在尝试Flink的新Python流API，并尝试使用./flink-1.6.1/bin/pyflink-stream.sh examples/read_from_kafka.py运行我的脚本。 python脚本非常简单，我只是想从一个现有的主题中获取内容并将所有内容发送到stdout（或默认情况下output方法在其中发出输出数据的日志目录中的* .ou […]

    标签：, , , ,

  • kafka-> flink-性能问题 - java

    时间：2020-8-4

    我正在查看一些kafka主题，这些主题每秒产生约3万条消息。我有一个flink拓扑设置，可以读取其中之一，聚合一点（5秒的窗口），然后（最终）写入数据库。 当我运行拓扑并删除除读取->聚合步骤之外的所有内容时，我每分钟只能收到约3万条消息。没有任何地方会发生背压。 我究竟做错了什么？ 编辑： 我无法更改有关主题空间的任何内容。每个主题都有一个分区，并且 […]

    标签：, , ,