ksql整合debezium创建连接器出现500

1、我是通过cp-ansible安装的kafka集群，版本是6.0.5
在ksql中创建连接器出现以下问题

这个报错是因为kafka没有加载mysql连接器，自己导入即可,jar包名称mysql-binlog-connector-java-0.19.1.jar和mysql-connector-java-8.0.16.jar，jar包位置放在
/usr/share/java/kafka 下。这是默认位置

[2022-03-09 13:29:01,343] WARN /connectors (org.eclipse.jetty.server.HttpChannel)
javax.servlet.ServletException: org.glassfish.jersey.server.ContainerException: java.lang.NoClassDefFoundError: com/mysql/cj/jdbc/Driverat org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:410)at org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:346)at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:366)at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:319)at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:205)at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799)at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:550)at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624)at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1434)at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)

如果出现一下问题是没有导入 debezium的包
Caused by: org.glassfish.jersey.server.ContainerException: java.lang.NoClassDefFoundError: Could not initialize class io.debezium.connector.mysql.MySqlConnectorConfigat org.glassfish.jersey.servlet.internal.ResponseWriter.rethrow(ResponseWriter.java:254)at org.glassfish.jersey.servlet.internal.ResponseWriter.failure(ResponseWriter.java:236)at org.glassfish.jersey.server.ServerRuntime$Responder.process(ServerRuntime.java:438)at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:263)at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)at org.glassfish.jersey.internal.Errors.process(Errors.java:292)at org.glassfish.jersey.internal.Errors.process(Errors.java:274)at org.glassfish.jersey.internal.Errors.process(Errors.java:244)at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265)at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:234)at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:680)at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:394)... 30 more

创建connector成功之后。但状态还是等待状态时，查看日志出现以下问题，解决方法是导入antlr4-runtime-4.7.2.jar之后重启ksql.

[2022-03-09 13:56:58,692] ERROR WorkerSourceTask{id=inmgn.student_Info_connector-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask)
org.apache.kafka.connect.errors.ConnectException: java.lang.NoClassDefFoundError: org/antlr/v4/runtime/CharStreamat io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:289)at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:104)at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:189)at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:239)at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)at java.util.concurrent.FutureTask.run(FutureTask.java:266)at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)at java.lang.Thread.run(Thread.java:750)

ksql整合debezium创建连接器出现500相关推荐

GNS3 cloud 连接错误_8次点击，30秒创建连接器，Ta竟然做到了！
作者:Ruma Sanyal Informatica混合集成平台产品市场总监根据"互联网世界统计"的数据,截止到2019年6月,全世界约有45亿人实现了互联互通.在最近的印度之旅 ...
8次点击，30秒创建连接器，Ta竟然做到了！
作者:Ruma Sanyal Informatica混合集成平台产品市场总监根据"互联网世界统计"的数据,截止到2019年6月,全世界约有45亿人实现了互联互通.在最近的印度之旅 ...
必需的 Debezium MySQL 连接器配置属性
必需的 Debezium MySQL 连接器配置属性官网地址: https://debezium.io/documentation/reference/1.5/connectors/mysql.ht ...
HM-3400: Create Connectors（HM-3400:创建连接器）
HM-3400: Create Connectors(HM-3400:创建连接器) In this tutorial you will learn how to weld two front trus ...
spring与struts2整合出现错误HTTP Status 500 - Unable to instantiate Action
在进行spring和struts2整合的时候因为大意遇到了一个问题,费了半天神终于找到了问题所在,故分享出来望广大博友引以为戒!! 我们都知道在spring和struts2整合时,spring接管了a ...
javaweb(05):tomcat服务器的安装、启动，IDEA整合Tomcat创建动态web工程
tomcat服务器的安装.启动下载及安装下载官网下载合适的版本:https://tomcat.apache.org/ 我装的是9.0.37版本. 安装把从官网下载的文件放到想要安装的位置,解压 ...
python创建空文本文件_Python干货：「文件处理整合」创建、打开、写入和删除...
什么是Python文件处理? Python文件处理就是如何在python中创建.打开.读取.写入和删除文件的示例.从文件(EXCELSheet.doc文件.文本文件.cv等)或Add中读取数据.是一个 ...
记录idea整合git 创建分支合并分支提交
创建项目在idea中创建所需的java项目 1(配置git 在File–>Setting->Version Control–>Git–>Path to Git executa ...
Debezium系列之：Debezium2.X之PostgreSQL数据库的Debezium连接器
Debezium系列之:Debezium2.X之PostgreSQL数据库的Debezium连接器一.概述二.连接器的工作原理 1.安全 2.快照 3.临时快照 4.触发临时快照 5.增量快照 6 ...

ksql整合debezium创建连接器出现500

ksql整合debezium创建连接器出现500相关推荐

最新文章

热门文章