阿里云文档 2025-01-17

配置SSL功能加密Kafka数据链接

SSL(Secure Sockets Layer)是一种网络协议,提供了一种在客户端和服务器之间建立安全连接的方法。启用SSL后,DataFlow集群中的所有数据传输,包括生产者、消费者与Broker之间的消息交互都会被加密,确保敏感信息在网络传输过程中不被窃听或篡改。本文为您介绍如何开启SSL,并使用SSL连接Kafka。

阿里云文档 2024-06-07

为Confluent集群开启公网

如果需要通过公网接入云消息队列 Confluent 版,您可以为集群开启公网。

文章 2022-08-22 来自:开发者社区

Flink / Kafka - Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy 排查与修复 ———————————————— 版权声明:本文为CSDN博主「BIT_666」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。 原文链接:https://blog.csdn.net/BIT_666/article/details/125419738

一.引言使用 Flink - Kafka 接数据 Source 时程序报错:org.apache.flink.runtime.JobException: Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy任务每次启动后持续10min左右,然后 RUNNING -> FAILED,如此重启失败了多次。二.问题现象1.任....

Flink / Kafka - Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy 排查与修复  ———————————————— 版权声明:本文为CSDN博主「BIT_666」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。 原文链接:https://blog.csdn.net/BIT_666/article/details/125419738
问答 2020-06-14 来自:开发者社区

spark2.1.0的kafka链接失败了:报错

in thread "main" java.lang.IllegalArgumentException: 'path' is not specified     at org.apache.spark.sql.execution.datasources.DataSource$$anonfun$9.apply(DataSource.scala:205)  &n...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注