连接器创建组织。阿帕奇。Kafka。连接运行时。分发。重新平衡需要例外
在连接器post请求创建中，我收到以下错误：
Error message : 500 Internal Server Error,
error response: {"error_code":500,"message":"org.apache.kafka.connect.runtime.distributed.RebalanceNeededException: Request cannot be completed because a rebalance is expected"}
Requst body:
{"name":"pg_sink_connector_ansv_mc","config":{"name":"pg_sink_connector_ansv_mc","connector.class":"io.confluent.connect.jdbc.JdbcSinkConnector","connection.user":"postgres","database.dbname":"ansv_mc","connection.password":"postgres","topics":"ansv_mc.public.discovery_channel_message","transforms":"unwrap","transforms.unwrap.type":"io.debezium.transforms.ExtractNewRecordState","database.server.name":"ansv_mc","database.port":"5432","auto.create":"true","database.hostname":"pg-common,"connection.url":"jdbc:postgresql://pg-common.postgres????????"}}
共有1个答案
您正在使用一个接收器连接器，简单地说，它是一个Kafka消费者，从Kafka读取记录并写入postgres。
当重新平衡正在进行时，Kafka消费者无法读取（Kafka正在将分区分配给组中的消费者）。请参阅此处的详细信息
这应该是一个间歇性问题，接收器连接器应该在以下迭代中恢复。
-
Selenium Webdriver（2.53）和java（jdk 7）。Mozilla Firefox ESR（45.2.0）在页面打开时立即崩溃，并显示错误消息： 出错
-
我想开发一个Kafka连接器，但为了快速测试，我想重新加载插件，而不是重新加载我的docker堆栈中的容器。有办法做到吗？ 实际上，我编译了连接器，并将jar文件移动到绑定在容器kafka connect上的文件夹中。移动文件后，我重新加载容器。 先谢谢你。
-
我有div，可以拖放到绘图区域。可以使用鼠标从源endpoint拖放到目标endpoint手动连接这些div。在这样创建的连接上，连接被分离，但endpoint保留，删除的连接可以通过上述相同的手动过程重新创建。现在，我还将以json格式的连接节点流程图形式的绘图保存到磁盘文件中。在加载文件时，流程图会完美地显示所有连接和节点。现在我在点击一个节点时删除一个连接，它就可以工作了。但是现在我不能再次
-
无法连接。无法建立到jdbc的连接：derby://localhost:1527/sample使用组织。阿帕奇。德比。jdbc。ClientDriver（DERBY SQL错误：错误代码：40000，SQLSTATE:XJ040，SQLERRMC:无法使用类加载器sun.misc.Launcher启动数据库'sample'$AppClassLoader@1d44bcfa，有关详细信息，请参见下一个
-
我正在windows计算机上使用Kafka，并尝试使用文件源连接器生成从文件到Kafka主题的内容。首先我启动了zookeeper，然后在启动Kafka Standalone Connector时启动了Kafka server（步骤3），我收到了很多警告，ReflectionsException 我对此没有什么疑问： 1。我需要添加一些jar文件吗 2。在libs文件夹下的Kafka dir中有一
-
我正在尝试从servlet（viewcurrentstock.java）检索一个属性到jsp（viewstock.jsp）。这里有一个例外提示：“org.apache.jasper.JasperException:java.lang.NullPointerException” 查看当前股票。JAVA viewstock.jsp 服务器日志：