我已经配置了群集网络,当尝试从一个码头堆栈中的服务运行Kafka MirrorMake时,我从服务日志中得到一个错误:
mirroring_mirror_maker | [2019-01-10 12:08:49,322] ERROR [mirrormaker-thread-1] Mirror maker thread failure due to (kafka.tools.MirrorMaker$MirrorMakerThread)
mirroring_mirror_maker | java.lang.IllegalStateException: No entry found for con
我有OSGI框架,在其中,我在一个包中接受REST调用,在rest调用中接收到的数据被发送给KAFKA brocker。还有另一个包将使用来自brocker的消息。
如果我在REST包之前初始化了KAFKA消费者包,那么REST bundleActivator就不会被调用,因为代码运行在KAFKA消费者代码的while循环中。如果在使用者包之前初始化REST包,则使用者包永远不会启动。
以下是KAFKA Bundle的激活者代码:
public class KafkaConsumerActivator implements BundleActivator {
private stat
我正在尝试使用debezium/connect:1.3 docker图像,并在尝试使用此tutorial创建弹性水槽时遇到以下错误。 正如this撰写文件所建议的那样,使用似乎不可用的debezium/connect-jdbc-es。 {
"error_code": 500,
"message": "Failed to find any class that implements Connector and which name matches io.confluent.connect.elasticsearch.Elasticsear
作为灾难恢复计划的一部分,我将实现Kafka MirrorMaker 2.0来在两个集群之间复制数据。 在这一点上,我只想做一个简单的主动/被动设计。 这是我的mm2.properties文件: # Licensed to the Apache Software Foundation (ASF) under A or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright own
我是否需要专门为Kafka JDBC源和宿连接器使用Confluent,或者我可以使用默认的apache Kafka实现吗?我尝试使用JDBC源配置作为worker属性来启动connect-standalone,但得到了以下异常: Failed to find any class that implements Connector and which name matches io.confluent.connect.jdbc.JdbcSourceConnector, available connectors are: PluginDesc{klass=class org.apache.ka
分布式服务启动成功: 2021-10-17 18:04:29,693 INFO Started Kafka {/,null,AVAILABLE} (org.apache.kafka.connect.runtime.rest.RestServer:319) 2021-10-17 18:04:29,693 INFO REST资源已初始化;服务器已启动,准备处理请求(org.apache.kafka.connect.runtime.rest.RestServer:319) 2021-10-17 18:04:29,693 INFO o.e.j.s.ServletContextHandler@1422