KafkaException:错误的请求类型18
KafkaException: 错误的请求类型18 是一个Kafka消息队列中的异常错误。Kafka是一种分布式流处理平台，用于高吞吐量、可扩展的数据流处理。它具有高度可靠性、持久性和容错性，适用于构建实时数据流应用程序。
在Kafka中，错误的请求类型18表示客户端发送了一个无效的请求类型。这可能是由于客户端代码中的错误或配置问题引起的。为了解决这个问题，可以采取以下步骤：
- 检查客户端代码：检查客户端代码中是否存在错误，例如请求类型的错误使用或错误的请求参数。确保代码中使用的请求类型是有效的，并且请求参数正确。
- 检查Kafka配置：检查Kafka集群的配置文件，确保配置正确。特别是检查与请求类型相关的配置项，例如producer.type和consumer.type等。
- 查看Kafka日志：查看Kafka集群的日志文件，以获取更多关于错误的详细信息。日志文件通常位于Kafka安装目录的logs文件夹中。根据日志中的错误信息，可以进一步确定问题的根本原因。
推荐的腾讯云相关产品：
- 云消息队列 CMQ：腾讯云提供的消息队列服务，具有高可靠性、高可用性和高性能的特点。它可以帮助用户构建可靠的消息通信系统，解耦应用程序之间的依赖关系。了解更多信息，请访问：云消息队列 CMQ
请注意，以上答案仅供参考，具体的解决方法可能因实际情况而异。如果问题仍然存在，建议查阅相关文档或咨询专业人士以获得更准确的帮助。
相关·内容
系统：
EC2实例类型: m5.2xlarge
操作系统: Ubuntu 14.04.5 LTS
内核版本: 4.4.0-1022-aws
vCPU: 8个核心
内存:32
Java版本: 1.8.0_171
我们在集群模式下运行KAFKA，包含两个kafka代理(10.0.51.1和10.0.51.2)和三个动物园管理员节点。我想升级我的AWS EC2实例，所以我运行了sudo apt-get update和sudo apt-get upgrade，并安装了linux-aws内核。更改实例类型后，我开始在10.0.51.2 kafka borker中得到以下错误：
18/06/08 07:0
浏览 0提问于2018-06-08得票数 13
我最近尝试使用来自Kafka主题的消息，但收到以下错误消息：
[2016-08-15 17:56:05,025] INFO Closing socket connection to /192.168.34.11. (kafka.network.Processor)
[2016-08-15 17:56:05,050] ERROR Closing socket for /127.0.0.1 because of error (kafka.network.Processor)
kafka.common.KafkaException: Wrong request type 18
at kafk
浏览 5提问于2016-08-16得票数 3
回答已采纳
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
回答已采纳
1回答
未能启动卡夫卡消费者结构
、、、
我正在为卡夫卡(kerberos)开发一个(Kerberos)的消费者类。我按照的建议，根据kerberos设置进行了必要的更改，最后出现了以下错误。我可以在本地设置同样的keytab/jks文件的Kafka集群安装程序。
Failed to start bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry'; nested exception is org.apache.kafka.common.KafkaException: Failed to construct kafka
浏览 0提问于2019-06-11得票数 0
我正在为kafka生产者使用python脚本，并得到以下错误：
cimpl.KafkaException: KafkaError{code=\_UNKNOWN_TOPIC,val=-188,str="Unable to produce message: Local: Unknown topic"}
我得到了以下错误：
cimpl.KafkaException: KafkaError{code=_UNKNOWN_TOPIC,val=-188,str="Unable to produce message: Local: Unknown topic"}
%4|1668
浏览 21提问于2022-11-13得票数 -1
我有一个码头设置运行卡夫卡经纪人与SSL。shell脚本用于执行证书生成步骤，并用于为kafka启用ssl。
我能够成功地使用keystore和trustore jks访问同一台机器中的kafka broker。( kafka工具和apache nifi都被配置为clientpublisher/使用者，运行良好)
但是，当我试图使用来自同一网络中不同计算机的证书连接代理时，它会产生错误。(Nifi说“无效密码或证书类型”，但我觉得这条错误信息具有误导性，原因可能不同)
任何暗示或想法是什么原因？
当我尝试使用kafka工具箱时，出现了以下错误：
org.apache.kafka.common.
浏览 11提问于2021-12-07得票数 0
2回答
我有一个3节点的Kafka集群。我已经启用了SASL_PLAINTEXT，它在6667端口上工作得很好。现在，我希望为同一群集中的不同端口启用SSL。我已经启用了trustore和Keystore证书。我从代理端进行了下面的配置。
listeners : SSL://localhost:6668
security.inter.broker.protocol : SSL
ssl.key.password : xxxx
ssl.keystore.location : /root/kafka.server.keystore.jks
ssl.keystore.password : xxxxx
ss
浏览 25提问于2020-03-16得票数 0
我对kafka很陌生，我使用Kafka生产者Java。面对这个问题，卡夫卡，Kafka: Invalid transition attempted from state COMMITTING_TRANSACTION to state ABORTING_TRANSACTION。
人们已经写到，只有在没有交易的情况下，才应该调用producer.abortTransaction() .知道如何检查飞行中是否有交易吗？以及如何清除/阻止它们？
这是我的密码：
try {
producer.send(record, new Callback() {
@Override
publ
浏览 2提问于2020-09-10得票数 2
回答已采纳
我有一个Spark流媒体应用程序从Kafka读取。我在电子病历上运行它。最近我实现了Kafka SSL。我正在创建Kafka客户端，如下所示。当应用程序试图读取信任库文件时，我在运行应用程序时遇到一个奇怪的错误。错误是： - Caused by: org.apache.kafka.common.KafkaException: org.apache.kafka.common.KafkaException: java.io.FileNotFoundException: /tmp/kafka.client.truststore.jks (No such file or directory) 导致此
浏览 21提问于2019-12-11得票数 1
回答已采纳
1回答
我试图使用卡夫卡消费对象从错误的/不存在的主题名中消费。下面是我在投票线之后的日志。
WARN 19508 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient : Error while fetching metadata with correlation id 22 : {dummyTopic=LEADER_NOT_AVAILABLE}
它只是记录控制台上的警告，而不是抛出异常。我想要处理这种情况。如何做到这一点？下面是我的消费者代码
Properties consumerProperties = new P
浏览 1提问于2018-02-15得票数 3
获取以下eeror- org.springframework.kafka.KafkaException:发送失败；嵌套异常是60000 ms后元数据中不存在的org.springframework.kafka.KafkaException主题topic_1。
浏览 5提问于2022-10-03得票数 0
回答已采纳
我已经使用以下属性设置了kafka consumer Properties consumerProperties = new Properties();
consumerProperties.put("bootstrap.servers",server);
consumerProperties.put("group.id",groupId);
consumerProperties.put("security.protocol", "SASL_PLAINTEXT");
consumerPro
浏览 42提问于2018-02-14得票数 2
回答已采纳
1回答
我在流集中构建了一个管道，用于从sql中读取数据并进行更改数据捕获。当我开始执行管道时，我会得到以下错误。
管道状态: START_ERROR: java.lang.NoClassDefFoundError: org/apache/kafka/ Pipeline /KafkaException
浏览 5提问于2017-04-18得票数 1
回答已采纳
1回答
我按照本教程使用Bluemix中的流分析服务与消息集线器：接口。
我收到了一个错误：
由: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException:无法找到LoginModule类:javax.security.auth.login.LoginException引起
谢谢
浏览 3提问于2016-05-24得票数 4
回答已采纳
1回答
我有技术问题，试图解决当部署我的应用程序spring引导应用程序与码头容器。
/tmp/tomcat-docbase.4737956707529585395.8080/deployments/app/certs/kafka.truststore.jks : org.apache.kafka.common.KafkaException: org.apache.kafka.common.KafkaException:未能加载SSL密钥存储库org.apache.kafka.common.KafkaException
/deployments是我在dockerfile中的工作程序配置。
我觉
浏览 1提问于2019-02-28得票数 5
回答已采纳
我不能让这个起作用。我正在尝试将一条简单的测试消息推送到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
我正在使用confluent-kafka。 我的代码是 producer = SimpleAvroProducer(producer_id="producer_1",
topic_name="events_topic",
broker_host= brkr_host,
broker_port= brkr_port,
sche
浏览 142提问于2021-09-07得票数 0
带卡夫卡连接器的EI611最新抛出错误：
org.apache.kafka.common.KafkaException:加载Zookeeper登录上下文'Client‘时的异常。。。。由: java.lang.SecurityException: java.io.IOException: java.io.IOException引起(没有此类文件或目录)
这个错误也是由其他人发布的：
有人找到解决办法了吗？你知道怎么修吗？
浏览 0提问于2017-10-20得票数 0
当我在kafka中执行以下命令时
./kafka-consumer-groups.sh --bootstrap-server sample-address:9092 --list
我面临着下面的错误
Error: Executing consumer group command failed due to org.apache.kafka.common.KafkaException: Failed to find brokers to send ListGroups
java.util.concurrent.ExecutionException: org.apache.kafka.common
浏览 1提问于2019-09-04得票数 6
回答已采纳
在我的计算机上进行本地测试：
index.hml
<!DOCTYPE html>
<html>
<head>
<!--script src="angular.js"></script-->
<script src="i18next.js"></script>
<script src="app.js"></script>
</head>
<body>
浏览 6提问于2014-11-28得票数 0
我正在通过Kafka模板向Kafka发送消息，但我想测试异常，所以我提供了错误的主题名称，但当我运行代码时，它说“获取相关id为2的元数据时出错：{ocf-oots-gr-outbound_123=LEADER_NOT_AVAILABLE”不可用，但主题本身是在Kafka中创建的，我也可以通过Kafka工具看到，当broker停止时，它也没有抛出异常。
代码：
KafkaTemplate<String, Object> kafkaTemplate = (KafkaTemplate<String, Object>) CommonAppContextProvider.get
浏览 19提问于2019-07-22得票数 0
回答已采纳
我有一个以FIPS模式运行的kafka集群，配置如下。
Brokers: 3, Zookeeper Nodes: 3
Kafka: 2.0.0, Scala: 2.12
Zookeeper: 3.4.14
Java - 8
bc-fips - 1.0.1
此群集运行良好，处于健康状态。
目前，我们已经升级了Kafka(2.4.0)和Java(11)版本，之后FIPS集群无法加载bc库并启动kafka。新的集群配置：
Brokers: 3, Zookeeper Nodes: 3
Kafka: 2.4.0, Scala: 2.12
Zookeeper: 3.4.14
Java - 11
bc-fi
浏览 1提问于2020-05-19得票数 1
回答已采纳
当我从运行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( kafka _2.11-0.10.0.0)和OSB 12c(12.2.1.2)之间的连接，用于消费来自kafka的OSB消息。
我遵循了在OSB中安装Kafka传输所需的步骤，这是成功的，但当我尝试使用Kafka的消息时，我得到的错误如下：
com.bea.wli.sb.transports.TransportException: org.apache.kafka.common.KafkaException: Failed to construct kafka consumer at oracle.ateam.sb.transp
浏览 0提问于2019-07-08得票数 0
1回答
我已经将我的使用者配置成分批接受来自主题的消息。我如何将它转发到一个新的主题？
我希望每个消耗的消息都作为自己的消息被转发。因此，X所消耗的消息量将产生X数量的消息。
下面是我当前的设置：
@KafkaListener(topics = "input")
@SendTo("output")
public ConsumerRecords consume(ConsumerRecords records) {
// Do things
return records;
}
下面是抛出的异常：
org.springframework.kafka.KafkaExc
浏览 1提问于2019-04-08得票数 0
回答已采纳
我正在尝试使用confluent_kafka来使用来自代理的一些消息。我得到了一个我完全理解的例外。我试图为不存在的主题/分区获得最早的偏移量。
我试图正确地处理这个异常，当我打印出异常时，我看到
cimpl.KafkaException: KafkaError{code=_UNKNOWN_PARTITION,val=-190,str="Failed to get offsets: Local: Unknown partition"}
我想在这里放置一个很好的尝试/除了块，并处理UNKNOWN_PARTITION错误代码，但是我找不到任何与_UNKNOWN_PARTITION值
浏览 8提问于2022-02-19得票数 0
我正在构建一个从IIS7服务器检索文件的iPhone应用程序。我正在使用一个普通的旧NSURLRequest来检索这个文件。如果我使用另一个web服务器，这个请求工作得很好，但是由于某些原因，这个服务器总是给我一个400个错误的请求。所以我看了一下NSURLRequest发送的请求，它看起来是这样的：
::1 [Wed Sep 01 20:18:53 -0400 2010]: GET /some.file
::1 [Wed Sep 01 20:18:53 -0400 2010]: HTTP/1.1
::1 [Wed Sep 01 20:18:53 -0400 2010]: Host: loc
浏览 0提问于2010-09-02得票数 1
回答已采纳
我想连接到卡夫卡使用端口80在我的Azure虚拟机。我在虚拟机上安装了Java和Kafka。我为端口80添加了入站端口规则。
我将port=80添加到Kafka的config/server.properties文件中。我成功地跑了动物园管理员。
当我试图连接到kafka时，我会发现以下错误：
KafkaServer id=0在KafkaServer启动期间发生致命错误。准备关闭(kafka.server.KafkaServer) org.apache.kafka.common.KafkaException:套接字服务器无法绑定到0.0.0.0:80:权限被拒绝
我可
浏览 4提问于2020-09-04得票数 0
回答已采纳
我在运行这段代码。streamingInputDF是卡夫卡主题的readStream。我运行的是spark 2.4.0和Kafka 0.10.2
val activityQuery = streamingInputDF.writeStream
.format("console")
.outputMode("append")
.start()
.awaitTermination()
当writeStream在streamingInputDF上被调用时，我看到卡夫卡代理抛出了这个异常
[2018-11-24 21:46:42,842] ERROR Closing s
浏览 0提问于2018-11-25得票数 0
回答已采纳
没有关于具体集成API网关和Codebuild的实际指南，所以我看了几个，并试图适应。
我根据设置了我的角色和策略，并成功地设置和运行了我的CodeBuild项目。
我已经设置了一个POST端点，引用了
我使用测试选项卡为端点发送
{ "project": "my-project" }
但是我得到了这样的回应
{
"Output": {
"__type": "com.amazon.coral.service#UnknownOperationException",
"messag
浏览 0提问于2019-08-18得票数 4
我有一个与Gmail集成的NodeJS应用程序。当我试图访问Gmail API时，会得到以下错误：
{
"error": {
"errors": [
{
"domain": "usageLimits",
"reason": "rateLimitExceeded",
"message": "User-rate limit exceeded. Retry after 2017-03-26T18:15:52.102Z"
}
]
浏览 1提问于2017-03-26得票数 1
回答已采纳
在spring-kafka-2.5.4.RELEASE版本中，当不同分区有多条失败记录时，如果FixedBackOff的maxAttempts设置为1，间隔不是-1L，则seekToCurrentErrorHandler会失败。
SeekToCurrentErrorHandler seekToCurrentErrorHandler =新SeekToCurrentErrorHandler(，新FixedBackOff(0L，1))；
尽管当maxAttemps计数为1时，为interval设置一个非-1L的值没有意义(因为不会有重试，因此也就没有重试间隔)，但是它是不是应该在启动时失败并报告相同
浏览 1提问于2020-12-10得票数 0
1回答
在之前的注释:这是更新的，并且有一个名为“error:数据库名称不能包含字符”的问题。但这是一个空格或空字符，不是一个点！我不知道这是否会有很大的不同，但除了这个问题外，这个问题的答案并没有进一步帮助我。另外，我使用Windows 7 (32位(我知道，这不是mongodb最好的东西)，我把描述做得更详细一些)。
关键是:我想在几天后第一次启动流星(之前一切都很好)，突然出现了这个错误：
W20150803-18:44:47.168(2)? (STDERR) C:\Users\Laptop\AppData\Local\.meteor\packag
es\meteor-tool\1.1.3\mt
浏览 0提问于2015-08-03得票数 2
2回答
我在远程Ubuntu服务器上安装了一个Apache (v.2.13-3.0.0)。我遵循本教程来保护我的集群：
但是，当我尝试用jaas文件启动Kafka时，命令如下：
export KAFKA_OPTS=-Djava.security.auth.login.config=<kafka-binary-
dir>/config/kafka_server_jaas.conf
./bin/kafka-server-start.sh ./config/server.properties
我收到错误：
[2021-11-12 10:30:47,864] INFO Registered k
浏览 2提问于2021-11-12得票数 3
我在一个简单的Kafka消费者程序上遇到了一些麻烦：
18/06/04 18:13:49 ERROR /log/log.txt: org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer
浏览 4提问于2018-06-04得票数 8
我试图运行卡夫卡制片客户发布一些信息给卡夫卡经纪人。我已经给出了通往Keystore/Trust商店的路径和密码。当我在Apache上部署这个消息时，我能够向代理发送消息。但是，当我试图在websphere上部署相同的应用程序时，会出现“未能加载SSL密钥存储库”的错误。我已授予这些目录读/写/执行权限。websphere是否需要不同的配置/设置？
Caused by: org.apache.kafka.common.KafkaException: org.apache.kafka.common.KafkaException: Failed to load SSL keystore /home
浏览 7提问于2022-11-16得票数 1
我正在编写一个脚本，在AWS管理的Kafka集群上刷新我的主题。每当我运行脚本时，我需要删除现有的数据，并再次删除和创建相同的主题。我期望脚本在我反复运行时打印出成功的删除和成功的创建。但是删除/创建失败了，每一次运行都会让我感到困惑。
以下是我的脚本：
# manage_topics.py
import sys
from confluent_kafka.admin import AdminClient, NewTopic
from confluent_kafka import KafkaError, KafkaException
if __name__ == '__main__
浏览 13提问于2022-07-25得票数 0
回答已采纳
最近在使用Message Hub服务时，我发现以前工作的应用程序在使用KafkaException或Failed to update metadata时开始出现故障。
我该如何解决这个问题？
浏览 0提问于2016-03-11得票数 1
我有一个Kafka集群运行在合流云上，但我无法从UI中重置提交偏移量。因此，我试图通过Kafka的CLI来做这件事，如下所示：
kafka-consumer-groups --bootstrap-server=my_cluster.confluent.cloud:9092 --list
但是，我遇到了下面的错误。我认为这与我如何认证有关。
Error: Executing consumer group command failed due to org.apache.kafka.common.KafkaException: Failed to find brokers to send List
浏览 58提问于2022-02-14得票数 1
回答已采纳
我在我的生产环境中遇到了这个奇怪的错误。我的Rails应用程序中有几个AJAX请求有GET方法，现在我决定更改这个安全错误漏洞。我把大部分的请求都改贴了。在本地环境和演示环境中，一切都很好，这几乎与生产环境相同。
请求：(CoffeeScript)
$(".vehicle_make_dropdown").on "change", ->
$.ajax(
url: "/get_maker_models"
data:
maker: $("#entry_vehicle_make").v
浏览 1提问于2014-09-18得票数 0
我试图使用Java运行我的Kafka Streams应用程序，并以K，V对的形式将我的汇合凭证作为环境变量传递。
但我面临一个错误的问题，因为-
- org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient
Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient
Caused by: java.lang.IllegalArgum
浏览 16提问于2022-01-10得票数 0
下面是试图读取流时所收到的错误。
Caused by: kafkashaded.org.apache.kafka.common.KafkaException: Failed to load SSL keystore /dbfs/FileStore/Certs/client.keystore.jks
Caused by: java.nio.file.NoSuchFileException: /dbfs/FileStore/Certs/client.keyst
当试图从Kafka读取流时，Databricks无法找到keystore文件。
df = spark.readStream \
.for
浏览 7提问于2022-11-08得票数 1
这就是代码 function loadDoc() {
var obj = {
"username": "234zu",
"subject": "qwertz",
"content": "qw",
"created_at": "2018-12-15 22:18:54",
"updated_at": "2018-12-15 22:18:54"
浏览 28提问于2019-01-19得票数 0
回答已采纳
我已经创建了一个示例代码来比较HttpPost方法在两个不同的Android操作系统v2.3和v4.0中的输出。我有一张正在使用运营商的3G服务的SIM卡。因此，我正在通过3G服务连接到互联网。代理服务器地址和端口由移动运营商自动设置，两者相同。
我的代码是这样的：
public class MainActivity extends Activity {
private final String TAG = "MainActivity";
@Override
public void onCreate(Bundle savedInstanceState
浏览 0提问于2012-07-09得票数 4
1回答
在AWS上部署Kafka
、、、、
我正在尝试在aws上部署kafka。运行kafka服务器时，我得到以下错误：
kafka.common.KafkaException: Socket server failed to bind to hostname:9092: Cannot assign requested address.
at kafka.network.Acceptor.openServerSocket(SocketServer.scala:309)
at kafka.network.Acceptor.<init>(SocketServer.scala:237)
浏览 9提问于2017-06-20得票数 0
回答已采纳
你好，我正在编写EFS，我有一个表单，现在我使用客户端ID、终结日期和启动日期发布静态数据。我正在调用getchildTransaction函数。
但是，当我提交表格时，我会发现以下错误：
PHP致命错误:未指定的SoapFault异常:soapenv:接收方日期字符串不能少于19个字符
如何通过约会？我传递以下参数值：
$soapFunctionParameters = Array('username' => "************", 'password' => "*******",'clien
浏览 0提问于2017-09-18得票数 1
尝试使用method参数(如 )会产生以下错误。
Python 3.2.3 (default, Sep 25 2013, 18:22:43)
>>> import urllib.request as r
>>> r.Request('http://example.com', method='POST')
Traceback (most recent call last):
File "<stdin>", line 1, in <module>
TypeError: __init__(
浏览 0提问于2013-12-18得票数 0
回答已采纳
1回答
使用阅读Kafka的Avro记录
、、、、
我正在使用 stream 2.3，并试图使用Dstreams (使用DStreams来获取特定的应用程序，而我们无法使用结构化流)从卡夫卡流中获取数据。
Kafka主题包含avro格式的数据。我希望使用Spark DStreams读取该数据，并将其解释为json字符串。
我想做这样的事，
val kafkaParams: Map[String, Object] = Map(
"bootstrap.servers" -> "kafka-servers",
"key.serializer" -> classOf[Strin
浏览 3提问于2022-11-23得票数 0
回答已采纳
我用java开发了一个原始的http贴子。我试图张贴一个文件到post请求转储网站。但它显示错误400坏请求。请让我知道需要做些什么来避免这个错误。
在此代码中，输出=>流以在服务器上写入。服务器上的文件名->路径，这里的文件名被激发到post.php
output.println("POST"+" "+filename+" HTTP/1.1\r");
//output.println("Content-Length: "+data.length());
outp
浏览 3提问于2015-03-18得票数 0
1回答
Spring循环发送消息
、、、
我使用spring依赖版本2.8.1，配置如下：
kafka:
bootstrap-servers: localhost:9092
producer:
acks: all
key-serializer: org.apache.kafka.common.serialization.StringSerializer
value-serializer: org.apache.kafka.common.serialization.StringSerializer
buffer-memory: 16384
我试图向一个主题发送大约65.
浏览 7提问于2022-02-08得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
