在Kubernetes / OpenShift中运行Kafka Connect Workers而不通过REST API发布配置?

我想在OpenShift上运行Kafka connect worker。我想使用OpenShift(自动)向外扩展。但是,如果通常在特定工作程序启动后通过REST调用手动提供连接器配置,则不清楚如何传递连接器配置。因此,问题是是否可以在没有REST调用的情况下在启动时向工作者提供连接器的完整规范。

flink1.4.2 使用kafka08jsontablesource,我们测试,kafka里没有数据的情况下,程序运行一段时间就会报这个exception

转自钉钉群21789141:flink1.4.2 使用kafka08jsontablesource,我们测试,kafka里没有数据的情况下,程序运行一段时间就会报这个exception,flink从1.4.2升级到1.5.3后,报找不到JsonRowSerializationSchema,是不是有些...

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图

如何把一个运行完好的Kafka搞崩

Kafka其实也只是一个JVM进程,要想把一个进程搞崩溃,相信大家的nice idea(骚操作)也不少。本文中只是用了一种很常见的方式来使得Kafka的进程崩溃,通过分析崩溃的原因来让我们可以更合理的使用Kafka。 你可以试着在一台普通的Linux机器上创建10000个分区的主题。比如下面示例中创...

Kafka与Logstash的数据采集对接 —— 看图说话,从运行机制到部署

基于Logstash跑通Kafka还是需要注意很多东西,最重要的就是理解Kafka的原理。 Logstash工作原理 由于Kafka采用解耦的设计思想,并非原始的发布订阅,生产者负责产生消息,直接推送给消费者。而是在中间加入持久化层——broker,生产者把数据存放在broker中,消费者从brok...

Windows OS上安装运行Apache Kafka教程

下面是分步指南,教你如何在Windows OS上安装运行Apache Zookeeper和Apache Kafka。 简介 本文讲述了如何在Windows OS上配置并启动Apache Kafka,这篇指南将会指导你安装Java和Apache Zookeeper。  Apache Kafk...

在Docker上运行Apache Kafka

本文讲的是在Docker上运行Apache Kafka,【编者的话】在研究Apache Kafka和Docker时,作者发现Docker是一个非常神奇的技术,它将开发过程简化的如此完美。又因为有wurstmeister/kafka和wurstmeister/zookeeper这两个镜像,运行Apac...

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

社区圈子

消息队列
消息队列
消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。
20+人已加入
加入
相关电子书
更多
任庆盛|Flink CDC + Kafka 加速业务实时化
消息队列 Kafka 版差异化特性
2019大数据技术公开课第五季—kafka 数据如何同步到 MaxCompute
立即下载 立即下载 立即下载

云消息队列 Kafka 版运行相关内容