org/apache/kafka/common/requests/AbstractResponse :NoClassDefFoundError
org/apache/kafka/common/requests/AbstractResponse是Kafka消息队列系统中的一个类，它是Kafka请求的抽象响应类。NoClassDefFoundError是Java虚拟机在运行时无法找到指定类的错误。
具体来说，org/apache/kafka/common/requests/AbstractResponse是Kafka中用于处理请求响应的基类。Kafka是一个分布式流处理平台，它通过将消息以流的形式进行处理和传输。AbstractResponse类定义了处理Kafka请求后返回的响应的通用结构和方法。
NoClassDefFoundError是Java虚拟机在运行时无法找到指定类的错误。这种错误通常发生在编译时存在对某个类的引用，但在运行时无法找到该类的情况下。可能的原因包括类路径配置错误、类文件缺失或不可访问等。
对于这个错误，可以采取以下步骤进行排查和解决：
- 检查类路径配置：确保类路径中包含了所需的Kafka库和依赖项。可以通过检查环境变量、构建工具配置或IDE设置来确认类路径的正确性。
- 检查类文件是否存在：确认org/apache/kafka/common/requests/AbstractResponse类文件是否存在于正确的位置。如果类文件缺失，可能需要重新编译或重新安装Kafka。
- 检查类的可访问性：确保AbstractResponse类对于当前的执行环境是可访问的。这包括检查类的访问修饰符、包的可见性以及类加载器的配置等。
总结起来，org/apache/kafka/common/requests/AbstractResponse是Kafka消息队列系统中处理请求响应的基类，而NoClassDefFoundError是Java虚拟机在运行时无法找到指定类的错误。在解决这个错误时，需要检查类路径配置、类文件是否存在以及类的可访问性等因素。
相关·内容
当我将现有的生产Kafka集群从Kafka0.8.2.1升级到Kafka0.11.0.1后，开始出现错误。
无法为新版本的库初始化kafka配置。
在我们的项目中，我们使用storm来处理实时的Kafka主题
Storm Version: 1.0.2
Storm-Kafka version: 1.0.2
Kafka-Version: 0.11.0.1 with Scala 2.11
错误日志：
java.lang.NoClassDefFoundError: org/apache/kafka/common/requests/AbstractResponse
at org.apache.s
浏览 15提问于2017-11-24得票数 1
1回答
我正在尝试创建一个Kafka生产者的java实例，它抛出了这个错误，但是当我运行控制台生产者时，它工作了。 我认为这个错误是由于导入 错误： [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 2.6.0
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 62abe01bee039651
[main] INFO org.apache.kafka.common.utils.AppInfoParser -
浏览 12提问于2020-10-08得票数 0
回答已采纳
尝试将使用springboot的springboot应用程序从2.8.4升级到2.9.3版本。
我遵循这里的说明，将kafka版本3.2.3作为一个单独的依赖项。
我的依赖关系如下所示
implementation("org.springframework.kafka:spring-kafka:2.9.3") {
exclude group: "org.apache.kafka", module: "kafka-streams"
exclude group: "org.apache.kafka", module:
浏览 22提问于2022-11-30得票数 0
回答已采纳
主题: OSGI Kafka客户端包由于缺少约束而导致框架异常。
我从Apache (org.apache.servicemix.bundles.kafka-clients-0.11.0.1_1.jar) ( kafka-clients ServiceMix，)下载了kafka-clients OSGI包。
下面是我的pom.xml
<dependency>
<groupId>org.apache.servicemix.bundles</groupId>
<artifactId>org.apache.servicemix.bund
浏览 0提问于2017-11-09得票数 2
我正在学习卡夫卡，当我试图实现一个简单的制片人，只会发送“你好世界”
package com.github.joe.kafka.tutorial1;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSer
浏览 12提问于2020-10-05得票数 0
回答已采纳
1回答
我正在构建一个旧的kafka (0.8.2.2)，并得到一个缺少的java类的运行时错误：
java.lang.NoClassDefFoundError: org/apache/kafka/common/KafkaException
当我查看libs/kafka_2.10-0.8.2.2.jar时，我看到了kafka/common/KafkaException的存在：
$ jar tf $CLASSPATH | grep KafkaException
kafka/common/KafkaException.class
因此，构建(gradlew jar)构造了类，类路径的开头缺少org/ap
浏览 3提问于2017-04-24得票数 0
回答已采纳
我正在使用v2.7.5开发一个简单的Spring，并试图将消息发送到事件中心。有人能指点我吗？
错误：
java.lang.RuntimeException: non-nullable field authBytes was serialized as null
at org.apache.kafka.common.message.SaslAuthenticateResponseData.read(SaslAuthenticateResponseData.java:137) ~[kafka-clients-3.1.2.jar:na]
at org.apache.kafka.co
浏览 45提问于2022-11-11得票数 -1
回答已采纳
在consumer上获取此kafka异常：
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'correlation_id': java.nio.BufferUnderflowException
at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:71)
at org.apache.kafka.common.requests.ResponseHeader.parse(ResponseHeader.
浏览 4提问于2017-06-07得票数 3
我对Apache和Spring相当陌生，我正在编写一个应用程序，它使用来自主题的信息并执行一些操作。
我使用@KafkaListener注释编写了一个简单的消费者，并在本地KafkaServer0.10.1.1上测试了它，它运行得很好。
现在，当我指向Kafka的DEV服务器(版本- 0.10.0.2.5)时，我看到客户端日志中出现了以下异常：
network.Selector - Connection with qm-alpha.activehealth.net/10.42.53.152 disconnected
java.io.EOFException: null
at org.a
浏览 4提问于2017-04-04得票数 2
回答已采纳
我们有几个阅读卡夫卡主题的flink应用程序，它们工作得很好。但最近，我们向现有的flink作业添加了一个新主题，它在启动时立即开始失败，并出现以下根错误：
Caused by: org.apache.kafka.common.KafkaException: java.lang.NoClassDefFoundError: net/jpountz/lz4/LZ4Exception
at org.apache.kafka.common.record.CompressionType$4.wrapForInput(CompressionType.java:113)
at org.apa
浏览 5提问于2020-07-31得票数 1
回答已采纳
我在Kubernetes中使用进行分布式基准测试。
根据测试计划，我得到了异常：
Uncaught Exception java.lang.OutOfMemoryError: Java heap space in thread Thread[Thread Group 1-45,5,main]. See log file for details.
在jmeter.log文件中：
2020-06-20 08:57:17,602 ERROR o.a.k.c.u.KafkaThread: Uncaught exception in thread 'kafka-producer-network-
浏览 1提问于2020-06-20得票数 0
回答已采纳
我正在集成Flink 1.8流和kafka 2.x(kafka_2.12-2.2.0，kafka_2.12-2.3.0)，并在启动flink作业几秒钟后遇到异常：
org.apache.kafka.common.protocol.types.SchemaException: Error computing size for field 'topics': Error computing size for field 'name': Missing value for field 'name' which has no default va
浏览 239提问于2019-07-23得票数 0
1回答
对于ApacheSparkVersion2.1，我想使用Kafka (0.10.0.2.5)作为结构化流的源。
在Kafka主题中，我有json消息(用Streamset数据收集器推动)。但是，我无法用以下代码阅读它：
kafka=spark.readStream.format("kafka") \
.option("kafka.bootstrap.servers","localhost:6667") \
.option("subscribe","mytopic").load()
msg=kafka.selectE
浏览 0提问于2017-03-30得票数 5
回答已采纳
我正在尝试使用Kafka Connect和kafka-connect-twitter在Github的jcustenborder中将Twitter推文引入Kafka。说明书上写着： mvn clean package
export CLASSPATH="$(find target/ -type f -name '*.jar'| grep '\-package' | tr '\n' ':')"
$CONFLUENT_HOME/bin/connect-standalone connect/connect-avro-do
浏览 47提问于2021-11-12得票数 0
回答已采纳
我的动物园管理员和Kafka服务器正在工作，但我不知道为什么下面的代码不能工作。
我曾经使用Kafka-python运行python的Kafka，但是幂等属性存在问题，所以我转而使用java。我只想用java测试运行基本的生产者代码，但不幸的是，它不起作用。我是爪哇新来的，请帮帮我。
这是我的基本生产者代码：
package Main;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apach
浏览 3提问于2020-12-11得票数 2
回答已采纳
我运行Samza是为了使用Scala中给定的Kafka主题中的消息。为了运行，我创建了一个samza-read.properties文件，其中包含：
systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
systems.kafka.samza.msg.serde=byte
systems.kafka.consumer.auto.offset.reset=largest
systems.kafka.consumer.zookeeper.connect=localhost:2181/
systems
浏览 4提问于2019-10-02得票数 1
回答已采纳
我刚刚完成了使用6.0.0 (ApacheKafkaVersion2.6.0)安装Kafka集群的工作。卡夫卡经纪人被部署在库伯奈特。向新主题生成消息可以正常工作，只要没有压缩。
然而，我只是试图生成一个快速压缩消息，并得到一个错误返回。因此，我查看了代理日志，并在代理中看到了以下异常：
[2020-11-24 13:14:37,834] ERROR (data-plane-kafka-request-handler-0:Logging) [ReplicaManager broker=1] Error processing append operation on partition custo
浏览 11提问于2020-11-24得票数 1
回答已采纳
我在我的log4j.properties中添加了一个log4j kafka附加器，但它并没有像我预期的那样工作。
在我发布这个问题之前，我检查了我的基于的log4j.properties，它大约是0.8。然而，我不是幸运。
这是我的log4j.properties
log4j.appender.Kafka=org.apache.kafka.log4jappender.KafkaLog4jAppender
log4j.appender.Kafka.topic=my-topic
log4j.appender.Kafka.brokerList=localhost:9092
log4j.appende
浏览 8提问于2016-02-25得票数 5
更新
为了提供一些上下文，使用LZ4压缩启用了Kafka主题。
当识别压缩类型时，尝试将LZ4与运行时由于某种原因可以找到的KafkaLZ4BlockInputStream相关联。
@Override
public InputStream wrapForInput(ByteBuffer inputBuffer, byte messageVersion, BufferSupplier decompressionBufferSupplier) {
try {
return new KafkaLZ4BlockInputStream(inputBuffer, decompres
浏览 18提问于2021-12-09得票数 1
我正试图在docker上运行我的kafka项目。如果我在本地运行这个项目，它可以正常工作，但如果我在docker上运行，我会收到以下错误消息 Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/kafka/clients/producer/Producer
at com.kafka.App.main(App.java:14)
Caused by: java.lang.ClassNotFoundException: org.apache.kafka.clients.pr
浏览 50提问于2019-06-18得票数 0
回答已采纳
我正尝试使用以下命令在独立的星火集群上部署一个使用Kafka主题作业的星火流：
./bin/spark-submit --class MaxwellCdc.MaxwellSreaming
~/cdc/cdc_2.11-0.1.jar --jars ~/cdc/kafka_2.11-0.10.0.1.jar,
~/cdc/kafka-clients-0.10.0.1.jar,~/cdc/mysql-connector-java-5.1.12.jar,
~/cdc/spark-streaming-kafka-0-10_2.11-2.2.1.jar
得到这个例外：
Exception in thr
浏览 1提问于2018-05-29得票数 1
回答已采纳
1回答
我在卡夫卡中得到了下面的错误，就像消费者的例外
在下面的一个错误中，它将打印null，与bufferUnderFowException类似。
2022-09-09 20:53:28.644 ERROR 31952 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : Consumer exception
java.lang.IllegalStateException: This error handler cannot process 'org.apache.kafka.common.protocol.typ
浏览 15提问于2022-09-09得票数 1
我试图使用v1.2.1发送一个基本的字符串有效载荷，但是它失败了，只有以下例外情况：
2015-09-03 11:50:39.729 ERROR 14418 --- [task-executor-3] [ ] o.s.integration.handler.LoggingHandler : org.springframework.messaging.MessageHandlingException: error occurred in message handler [org.springframework.integr
浏览 3提问于2015-09-03得票数 1
回答已采纳
Spring Boot: 2.0.3版本 org.apache.kafka.kafka-streams: 1.0.0 Org.apache.kafka.kafka-客户端: 1.0.0 org.springframwork.kafka:spring-kafka-test:2.1.7.RELEASE 我有一个使用Kafka的Spring启动应用程序。我正在尝试使用https://blog.mimacom.com/testing-apache-kafka-with-spring-boot/来创建一个集成测试。 当我添加@EmbeddedKafka注解时，我在运行 org.springframew
浏览 92提问于2019-04-30得票数 0
回答已采纳
1回答
如何让系统中的警报卡夫卡连接器是与雪花数据库？
当前producer.properties是：
bootstrap.servers =XX.XX.XX.XX0: 9092,XX.XX.XX.XX1: 9092,XX.XX.XX.XX2: 9092
compression.type = none
日志目录中的错误: connect.logs中的一些dates=
第一个
[2022 - 06 - 20 14: 52: 10, 239] WARN[Producer clientId = producer - 2] Received invalid metadata error in produce
浏览 21提问于2022-04-15得票数 0
我一直在使用Java创建一个Kafka生产者示例。我一直在发送正常的数据，这只是“测试”+整数作为价值卡夫卡。我使用了下面的属性，在启动了生产者客户端之后，消息正在传递，在此过程中，我会杀死代理，然后突然收到下面的错误消息，而不是重新尝试。
使用具有3个分区和复制因子的3个代理和主题作为3，而不使用min-insync-副本。
下面的是配置了 config.put(ProducerConfig.ACKS_CONFIG，“all”)的属性；
config.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION，“1”；config.pu
浏览 3提问于2019-01-09得票数 1
1回答
我正在尝试创建一个简单的Flink Kafka消费者
public class ReadFromKafka {
public static void main(String[] args) throws Exception {
// create execution environment
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
Properties properties = new Properties();
propert
浏览 11提问于2019-07-13得票数 1
1回答
目前，我正在使用PlainLoginModule对用户进行身份验证。但是，我现在用这里列出的代码创建了一个jar，并希望使用它而不是PlainLoginModule：。
我将jar文件放入~/libs文件夹并添加了listener.name.sasl_ssl.plain.sasl.server.callback.handler.class=com.synopsys.demo.DemoApplication
到我的server.properties和kafka_server_jaas.conf到：
KafkaServer {
org.apache.kafka.common.securit
浏览 4提问于2019-10-29得票数 0
回答已采纳
我试图使用Spring consumer.However从Kafka主题中使用信息，我看到了下面的错误。当我使用本地机器中设置的kafka主题的消息时，这个功能很好-
org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1警告o.apache.kafka.clients.NetworkClient -引导代理<hostname>:9092断开连接
我能够使用命令行读取消息。
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topi
浏览 2提问于2017-09-20得票数 0
回答已采纳
3回答
我试图在apache版本4.0.3中为Kafka生产者创建一个简单的包。
这是我的Java代码
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("retries", 0);
props.put("batch.size", 16384);
props.put("linger.ms", 1);
浏览 0提问于2016-01-12得票数 3
我是卡夫卡新手，我试着安装和运行控制台用户，但是得到了错误的java.lang.IllegalStateException: There are no in-flight requests for node -1。
我尝试过的环境如下
Kafka Version kafka_2.13-2.6.0
MacOS java11 Fails
MacOS java 1.8 Fails
Windows 10 Java11 Success
下面是我正在执行的详细步骤。同样的步骤也适用于Windows。
步骤1下载卡夫卡
我刚从下载了卡夫卡
步骤2启动动物园管理员服务，这是很好的工作。
我要在下面的命令下
浏览 21提问于2020-08-30得票数 2
我使用Heroku Kafka，它运行0.10.1.1并使用SSL。它们只支持最新的协议。
Heroku Kafka使用SSL进行身份验证，颁发客户端证书和密钥，并提供CA证书。我将它们分别放在client_cert.pem、client_key.pem和trusted_cert.pem中，并运行以下命令来构建密钥库：
openssl pkcs12 -export -in client_cert.pem -inkey client_key.pem -certfile client_cert.pem -out client.p12
keytool -importkeystore -srckeys
浏览 0提问于2017-01-31得票数 2
回答已采纳
1回答
kafka- console -producer.sh和kafka-console-console. am的控制台命令运行正常，但是当我尝试使用api生产或消费时，我无法！有人能告诉我我的scala代码有什么问题吗？
import java.util.Properties
import org.apache.kafka.clients.producer.{KafkaProducer, ProducerRecord}
object ScalaProducerExample {
val topic = "test"
val brokers = "<bro
浏览 1提问于2018-05-25得票数 0
当我试图通过application.yaml配置kafka时，在配置使用者和生产者以及avro序列化程序和序列化程序时会出现错误。这个应用程序是用kotlin写的。application.yaml：
spring:
application:
name: test
cloud:
consul:
enabled: false
stream:
bindings:
input:
destination: dest
group: group
consumer:
浏览 6提问于2020-08-25得票数 0
我正在尝试使用Kerberos从ActiveMQ桥向Kafka (Cloudera)生成消息。
ActiveMQ v5.15.4
Camel：2.21.1
Kafka客户端：1.1.0
服务器版本：Apache2.4.6 (CentOS)
camel.xml代码片段是：
<log message="Started The Producer Route" />
<to uri="kafka://10.100.70.00:9092?topic=MyEvents.s1.v1&brokers=10.100.70.00:9
浏览 0提问于2018-06-22得票数 2
我正在尝试编写java api来创建kafka主题。我有Kafka版本0.11.0.0。我在堆栈溢出中进行了搜索，并尝试了相同的方法。但无论主题是否存在，它总是给我异常。
Exception in thread "main" java.lang.NoClassDefFoundError:
org/apache/kafka/common/errors/TopicExistsException
at kafka.admin.AdminUtils.createTopic(AdminUtils.scala)
at kafkaStream.Processor.CreateTop
浏览 3提问于2017-08-25得票数 0
回答已采纳
我有一个运行FlinkSQL的Flink作业，其设置如下：
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
final EnvironmentSettings settings =
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();
final StreamTableEnvironment tEnv = StreamTableEnviro
浏览 3提问于2021-10-26得票数 0
回答已采纳
当我从运行Kafka原生消息中心示例代码时，我得到了以下异常：
Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:320)
at org.apache.kafka.clients.producer.KafkaProducer.<init>
浏览 2提问于2015-11-05得票数 2
我想了解一下Kafka连接模块的开发生命周期。
遵循，我想使用"connect api“编写一个自定义的Kafka连接模块，但我不知道从哪里开始。有没有一些最小的例子来说明如何做到这一点？项目设置等？
顺便说一句，我构建了这个，并试图(在谷歌云上)运行它，但我发现了错误--显然是一个缺失的依赖项，但我不知道该添加什么。当然，这可能只应该在融合平台上运行。如果它可以在其他地方运行，那就太好了。但是如果它不能，我想知道如何从头开始构建一个，因此我提出了这个问题。
java.lang.NoClassDefFoundError: org/apache/kafka/common/config/C
浏览 1提问于2016-03-22得票数 2
回答已采纳
9.0客户端使用来自运行在远程system.My生产者上的两个代理的消息的客户端运行良好，能够向代理发送消息，但我的使用者无法使用这些messages.Consumer，而producer在我的本地系统上运行，两个代理在aws上运行。每当我试图运行消费者。下面的错误出现在代理日志上。
ERROR Closing socket for /122.172.17.81 because of error (kafka.network.Processor)
org.apache.kafka.common.protocol.types.SchemaException: Error reading fiel
浏览 10提问于2016-06-01得票数 5
回答已采纳
我正在开发一个Spark应用程序，它使用Spark和Java侦听Kafka流。
我使用kafka_2.10-0.10.2.1。
我为Kafka属性设置了各种参数：bootstrap.servers、key.deserializer、value.deserializer等。
我的应用程序编译得很好，但是当我提交它时，它会失败，并出现以下错误：
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/kafka/common/serialization/StringDeserializer
我确实将
浏览 14提问于2017-06-25得票数 2
回答已采纳
我正在尝试在我的项目中使用Spring Kafka，其中spring boot版本是2.2.2.RELEASE，kafka版本是2.3.x。 implementation 'org.springframework.kafka:spring-kafka' 我已经设置了KafkaConfig类和侦听器类： @EnableKafka
@Configuration
public class KafkaConfig {
Config cfg = new Config();
@Bean
public ConsumerFactory<String, String>
浏览 473提问于2020-10-22得票数 1
回答已采纳
当我试图从Kafka中读取时，我得到了以下错误
java.lang.IllegalArgumentException: Unknown compression type id: 5
at org.apache.kafka.common.record.CompressionType.forId(CompressionType.java:46)
at org.apache.kafka.common.record.Record.compressionType(Record.java:260)
at org.apache.kafka.common.record.LogEntry.isCompresse
浏览 0提问于2019-01-31得票数 1
我正在我的本地机器上测试storm+kafka集成。我有storm版本1.2.3和Kafka 2.5.0。我使用https://github.com/pvillard31/storm-kafka-kerberos/blob/master/src/main/java/example/KafkaStormKafkaTopology.java中的代码作为我的测试代码。 每当我提交拓扑时，我都会得到以下错误 Unable to get offset lags for kafka. Reason: org.apache.kafka.shaded.common.config.ConfigExceptio
浏览 157提问于2020-11-27得票数 1
因为我是Kafka的新手，所以我能够读取文件中的记录，并通过生产者将消息发送到Kafka主题，但不能通过消费者消费相同的主题。
注意:您可以从任何文本文件读取数据，我使用的是kafka_2.11-0.9.0.0版本
下面是我的代码：
package implementation;
import java.io.BufferedReader;
//import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
//im
浏览 17提问于2017-12-21得票数 1
我不能让这个起作用。我正在尝试将一条简单的测试消息推送到kafka主题。以下是代码和错误
Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafkaBrokerfqdn:6667");
props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SASL_PLAINTEXT");
props.put(ProducerConfig.ACKS_CONFI
浏览 3提问于2018-04-17得票数 0
我试图按照kafka命令运行(我们使用的是kafka版本0.9) -
bin\windows\kafka-console-producer.bat --broker-list localhost --producer.config config\action-ssl.properties --topic topic_name
行动-ssl.properties.属性-
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="action" passwo
浏览 3提问于2020-09-16得票数 0
我有一个码头设置运行卡夫卡经纪人与SSL。shell脚本用于执行证书生成步骤，并用于为kafka启用ssl。
我能够成功地使用keystore和trustore jks访问同一台机器中的kafka broker。( kafka工具和apache nifi都被配置为clientpublisher/使用者，运行良好)
但是，当我试图使用来自同一网络中不同计算机的证书连接代理时，它会产生错误。(Nifi说“无效密码或证书类型”，但我觉得这条错误信息具有误导性，原因可能不同)
任何暗示或想法是什么原因？
当我尝试使用kafka工具箱时，出现了以下错误：
org.apache.kafka.common.
浏览 11提问于2021-12-07得票数 0
我遇到了一个问题，试图从一个汇合的云集群复制到另一个。我一直在跟踪关于如何做到这一点的汇合文档，但是我遇到了一致的失败，我不得不假设这是由于我的配置中的一个错误造成的。
配置如下：
{
"name": "kafka_topics_replication",
"config": {
"name": "kafka_topics_replication",
"connector.class": "io.confluent.connect.replicator.Replica
浏览 26提问于2020-07-14得票数 0
1回答
我已经启动并运行了一个AWS MSK集群。连接到它并运行此命令以创建名为topicoteste的测试主题
usr/local/kafka_2.13-2.5.0/bin/kafka-topics --create --bootstrap-server BOOTSTRAP_STRING_HERE --partitions 1 --replication-factor 3 --topic topicoteste
这是我得到的两个错误。有什么建议吗？
Error while executing topic command : org.apache.kafka.common.errors.Timeout
浏览 112提问于2021-01-25得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
