久久久久久久av_日韩在线中文_看一级毛片视频_日本精品二区_成人深夜福利视频_武道仙尊动漫在线观看

  • <i id='6Psjq'><tr id='6Psjq'><dt id='6Psjq'><q id='6Psjq'><span id='6Psjq'><b id='6Psjq'><form id='6Psjq'><ins id='6Psjq'></ins><ul id='6Psjq'></ul><sub id='6Psjq'></sub></form><legend id='6Psjq'></legend><bdo id='6Psjq'><pre id='6Psjq'><center id='6Psjq'></center></pre></bdo></b><th id='6Psjq'></th></span></q></dt></tr></i><div class="qwawimqqmiuu" id='6Psjq'><tfoot id='6Psjq'></tfoot><dl id='6Psjq'><fieldset id='6Psjq'></fieldset></dl></div>

      <legend id='6Psjq'><style id='6Psjq'><dir id='6Psjq'><q id='6Psjq'></q></dir></style></legend>

      1. <tfoot id='6Psjq'></tfoot>

        <small id='6Psjq'></small><noframes id='6Psjq'>

          <bdo id='6Psjq'></bdo><ul id='6Psjq'></ul>

      2. kafka-connect-jdbc:SQLException:僅在使用分布式模式時沒

        kafka-connect-jdbc : SQLException: No suitable driver only when using distributed mode(kafka-connect-jdbc:SQLException:僅在使用分布式模式時沒有合適的驅動程序)

              <bdo id='Nib8m'></bdo><ul id='Nib8m'></ul>

              <small id='Nib8m'></small><noframes id='Nib8m'>

              <i id='Nib8m'><tr id='Nib8m'><dt id='Nib8m'><q id='Nib8m'><span id='Nib8m'><b id='Nib8m'><form id='Nib8m'><ins id='Nib8m'></ins><ul id='Nib8m'></ul><sub id='Nib8m'></sub></form><legend id='Nib8m'></legend><bdo id='Nib8m'><pre id='Nib8m'><center id='Nib8m'></center></pre></bdo></b><th id='Nib8m'></th></span></q></dt></tr></i><div class="qwawimqqmiuu" id='Nib8m'><tfoot id='Nib8m'></tfoot><dl id='Nib8m'><fieldset id='Nib8m'></fieldset></dl></div>
              <tfoot id='Nib8m'></tfoot>

                  <tbody id='Nib8m'></tbody>
                  <legend id='Nib8m'><style id='Nib8m'><dir id='Nib8m'><q id='Nib8m'></q></dir></style></legend>

                • 本文介紹了kafka-connect-jdbc:SQLException:僅在使用分布式模式時沒有合適的驅動程序的處理方法,對大家解決問題具有一定的參考價值,需要的朋友們下面隨著小編來一起學習吧!

                  問題描述

                  我們已經成功地使用了 mySQL - 使用 jdbc 獨立連接器的 kafka 數據攝取,但現在面臨在分布式模式下使用相同的問題(作為 kafka 連接服務).

                  We have successfully used mySQL - kafka data ingestion using jdbc standalone connector but now facing issue in using the same in distributed mode (as kafka connect service ).

                  connect-distributed.properties 文件-

                  connect-distributed.properties file-

                  bootstrap.servers=IP1:9092,IP2:9092
                  group.id=connect-cluster
                  key.converter.schemas.enable=true
                  value.converter.schemas.enable=true
                  offset.storage.topic=connect-offsets
                  offset.storage.replication.factor=2
                  config.storage.topic=connect-configs
                  config.storage.replication.factor=2
                  status.storage.topic=connect-status
                  status.storage.replication.factor=2
                  offset.flush.interval.ms=10000
                  plugin.path=/usr/share/java,/usr/share/java/kafka-connect-jdbc
                  

                  我有我的連接器罐子-

                  /usr/share/java/kafka-connect-jdbc
                  
                  -rw-r--r-- 1 root root  906708 Jul 29 01:18 zookeeper-3.4.13.jar
                  -rw-r--r-- 1 root root   74798 Jul 29 01:18 zkclient-0.10.jar
                  -rw-r--r-- 1 root root 5575351 Jul 29 01:18 sqlite-jdbc-3.8.11.2.jar
                  -rw-r--r-- 1 root root   41203 Jul 29 01:18 slf4j-api-1.7.25.jar
                  -rw-r--r-- 1 root root  658466 Jul 29 01:18 postgresql-9.4-1206-jdbc41.jar
                  -rw-r--r-- 1 root root 1292696 Jul 29 01:18 netty-3.10.6.Final.jar
                  -rw-r--r-- 1 root root  489884 Jul 29 01:18 log4j-1.2.17.jar
                  -rw-r--r-- 1 root root  211219 Jul 29 01:18 kafka-connect-jdbc-5.0.0.jar
                  -rw-r--r-- 1 root root  317816 Jul 29 01:18 jtds-1.3.1.jar
                  -rw-r--r-- 1 root root   87325 Jul 29 01:18 jline-0.9.94.jar
                  -rw-r--r-- 1 root root   20844 Jul 29 01:18 common-utils-5.0.0.jar
                  -rw-r--r-- 1 root root   20437 Jul 29 01:18 audience-annotations-0.5.0.jar
                  -rw-r----- 1 root root 2132635 Nov 11 16:31 mysql-connector-java-8.0.13.jar
                  

                  我可以通過這種方式運行腳本來運行獨立模式-

                  I am able to run the standalone mode by running the script in this way-

                  /usr/bin/connect-standalone /etc/kafka/connect-standalone.properties /etc/kafka-connect-jdbc/source-quickstart-mysql.properties
                  

                  但是當我嘗試調用 REST API 來運行分布式模式連接器時,出現錯誤:

                  But when I try to invoke the REST API to run a distributed mode connector , I get the error:

                  curl -X POST -H "Accept:application/json" -H "Content-Type:application/json" X.X.X.X:8083/connectors/ -d '{"name": "linuxemp-connector", "config": { "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector", "tasks.max": "1", "connection.url": "jdbc:mysql://Y.Y.Y.Y:3306/linux_db?user=groot&password=pwd","table.whitelist": "emp","mode": "timestamp","incrementing.column.name":"empid","topic.prefix": "mysqlconnector-" } }'
                  

                  錯誤-

                  {"error_code":400,"message":"Connector configuration is invalid and contains the following 2 error(s):\nInvalid value java.sql.SQLException: No suitable driver found for jdbc:mysql://Y.Y.Y.Y:3306/linux_db?user=groot&password=pwd for configuration Couldn't open connection to jdbc:mysql://Y.Y.Y.Y:3306/linux_db?user=groot&password=pwd\nInvalid value java.sql.SQLException: No suitable driver found for jdbc:mysql://Y.Y.Y.Y:3306/linux_db?user=groot&password=pwd for configuration Couldn't open connection to jdbc:mysql://Y.Y.Y.Y:3306/linux_db?user=groot&password=pwd\nYou can also find the above list of errors at the endpoint `/{connectorType}/config/validate`"}
                  

                  注意-連接器 jars 放置在所有連接節點上,plugin.path 在所有連接節點上都相同,并且 kafka-connect 服務已啟動并運行.

                  note- connector jars are placed on all connect nodes , plugin.path is same on all connect nodes and kafka-connect service is up and running .

                  我錯過了什么?為什么我無法提交 REST 調用來啟動此 mysql 管道的分布式連接工作器/任務?這在獨立模式下非常有效.但是在分布式模式下拋出錯誤.

                  What am I missing ? Why am I not able to submit REST call to start a distributed connect worker/task for this mysql pipeline ? This works absolutely fine with standalone mode . But throws error with distributed mode .

                  請幫忙!

                  謝謝!

                  推薦答案

                  通過修復以下問題,問題得到解決 -

                  By fixing below things, the issue got resolved -

                  1.修改/usr/share/java/kafka-connect-jdbc/mysql-connector-java-8.0.13.jar的權限為7552.在插件路徑中只保留/usr/share/java.

                  1.Changed permissions of /usr/share/java/kafka-connect-jdbc/mysql-connector-java-8.0.13.jar to 755 2.Keep only /usr/share/java in plugin path.

                  3.更改我的sql表結構,使其具有一個主鍵和一個具有增量性質或時間戳的列屬性.

                  3.Change my sql table structure to have one primary key and one column property with incremental nature or timestamp.

                  這篇關于kafka-connect-jdbc:SQLException:僅在使用分布式模式時沒有合適的驅動程序的文章就介紹到這了,希望我們推薦的答案對大家有所幫助,也希望大家多多支持html5模板網!

                  【網站聲明】本站部分內容來源于互聯網,旨在幫助大家更快的解決問題,如果有圖片或者內容侵犯了您的權益,請聯系我們刪除處理,感謝您的支持!

                  相關文檔推薦

                  How to use windowing functions efficiently to decide next N number of rows based on N number of previous values(如何有效地使用窗口函數根據 N 個先前值來決定接下來的 N 個行)
                  reuse the result of a select expression in the quot;GROUP BYquot; clause?(在“GROUP BY中重用選擇表達式的結果;條款?)
                  Does ignore option of Pyspark DataFrameWriter jdbc function ignore entire transaction or just offending rows?(Pyspark DataFrameWriter jdbc 函數的 ignore 選項是忽略整個事務還是只是有問題的行?) - IT屋-程序員軟件開發技
                  Error while using INSERT INTO table ON DUPLICATE KEY, using a for loop array(使用 INSERT INTO table ON DUPLICATE KEY 時出錯,使用 for 循環數組)
                  pyspark mysql jdbc load An error occurred while calling o23.load No suitable driver(pyspark mysql jdbc load 調用 o23.load 時發生錯誤 沒有合適的驅動程序)
                  How to integrate Apache Spark with MySQL for reading database tables as a spark dataframe?(如何將 Apache Spark 與 MySQL 集成以將數據庫表作為 Spark 數據幀讀取?)

                    1. <tfoot id='tmqPB'></tfoot>

                        <legend id='tmqPB'><style id='tmqPB'><dir id='tmqPB'><q id='tmqPB'></q></dir></style></legend>
                          <bdo id='tmqPB'></bdo><ul id='tmqPB'></ul>

                            <small id='tmqPB'></small><noframes id='tmqPB'>

                              <tbody id='tmqPB'></tbody>
                          • <i id='tmqPB'><tr id='tmqPB'><dt id='tmqPB'><q id='tmqPB'><span id='tmqPB'><b id='tmqPB'><form id='tmqPB'><ins id='tmqPB'></ins><ul id='tmqPB'></ul><sub id='tmqPB'></sub></form><legend id='tmqPB'></legend><bdo id='tmqPB'><pre id='tmqPB'><center id='tmqPB'></center></pre></bdo></b><th id='tmqPB'></th></span></q></dt></tr></i><div class="qwawimqqmiuu" id='tmqPB'><tfoot id='tmqPB'></tfoot><dl id='tmqPB'><fieldset id='tmqPB'></fieldset></dl></div>
                            主站蜘蛛池模板: 91午夜理伦私人影院 | 亚洲一级片在线观看 | 一区二区国产精品 | 国产免费一区二区三区 | 六月丁香综合 | 一级片免费 | 国产午夜精品视频 | 国产亚洲一区二区三区 | av黄| 亚洲国产毛片 | 成人一级视频 | 这里都是精品 | 日韩大片在线观看 | av黄色在线 | 国产精品毛片一区视频播 | 成人黄色在线观看 | 欧美a级成人淫片免费看 | 黄色av免费观看 | 天美传媒在线观看 | 欧美黑人一区二区三区 | 日韩在线免费 | 黄色欧美视频 | 精品国产欧美一区二区三区成人 | 一区免费视频 | 免费a视频| 亚洲精品欧美 | 中文字幕第一 | av高清在线| 人人爱人人澡 | 久久福利网 | 香港三日本三级少妇66 | 97精品超碰一区二区三区 | 日本乱轮视频 | 日韩免费看片 | 色多多视频在线观看 | 久久性生活视频 | 欧美日韩高清在线 | 欧美bbb| 色噜噜狠狠一区二区三区果冻 | 夜夜嗨av一区二区三区 | 亚洲色吧 |