如果主题不存在，Kafka生产者挂起
如果主题不存在，Kafka生产者会挂起，等待主题被创建或者存在。Kafka是一个分布式流处理平台，它通过将数据分成多个分区并在多个服务器上进行复制来实现高可用性和容错性。每个分区都有一个唯一的标识符，称为主题。生产者负责将数据发布到指定的主题中。
当生产者尝试向一个不存在的主题发送消息时，Kafka会根据配置的策略来处理这种情况。默认情况下，生产者会等待主题被创建或者存在，然后再发送消息。这意味着生产者会挂起，直到主题可用。
在等待期间，生产者可以选择定期检查主题是否已经创建或者存在。一旦主题可用，生产者会继续发送消息。如果在一定的时间内主题仍然不存在，生产者可以选择抛出异常或者执行其他的错误处理逻辑。
对于这种情况，腾讯云提供了一系列的云原生产品来支持Kafka的使用。例如，腾讯云消息队列 CKafka 是基于 Apache Kafka 构建的高可用、高吞吐量的消息队列服务，可以满足大规模数据流的处理需求。您可以通过腾讯云 CKafka 的控制台或者 API 来创建和管理主题，以及配置生产者和消费者。
更多关于腾讯云 CKafka 的信息，请访问以下链接：
请注意，以上答案仅供参考，具体的实现和配置可能因不同的环境和需求而有所差异。
相关·内容
2回答
我刚接触Kafka，正在尝试实现一个简单的生产者，将数据发送到一个主题。如果该主题不存在，我希望将sutiation作为异常处理。log.error("Failed to send message ",e); producer.flush();}
但是，如果该主题不存在[kafka-producer-network-thread | A
浏览 34提问于2019-08-08得票数 1
回答已采纳
Kafka有自己的一组配置，可以以编程方式创建主题。
对于生产者(java) API?有类似的东西吗？
浏览 7提问于2022-06-22得票数 2
回答已采纳
我有问题，在启动卡夫卡在微软Windows 10 Pro的生产者。Zookeper和kafka服务器启动正常。我也不存在创建、列出和删除主题的问题。以下是错误：
警告生产者clientId=控制台-生产者引导代理本地主机:2181 (id：-1齿条: null)断开连接(org.apache.kafka.clients.NetworkClient)
浏览 9提问于2021-12-13得票数 0
1回答
查询:将路由器接口作为kafka集群的生产者。问题2. kafka消费者可以在不指定主题的情况下拉取数据吗？我刚刚检查了Kafka broker配置是否有"auto.create.topics.enable“字段。如果</e
浏览 1提问于2014-06-18得票数 0
我正在为Apache使用Spring，并创建了一个服务，该服务通过Spring的org.apache.kafka.clients.producer(通过Spring的KafkaTemplate )使用卡夫卡生产者( Kafka Producer，KafkaTemplate)向主题发送消息。在目标Kafka集群上，我禁用了自动主题创建。使用这里列出的生产者配置的组合( )，我成功地控制了重试请求的次数、重试之间的时间等等。如果我提供了一个不存在
浏览 4提问于2020-02-17得票数 2
回答已采纳
我在golang中使用kafka-go来创建生产者和消费者。目前，我可以创建一个生产者，但我希望消费者一旦一个主题的生产者被创建，而不是每次都被创建。意味着对于每个主题，一个消费者只创建一次。此外，当需要为一个主题创建更多的消费者来平衡负载时，它就会被创建。有没有什么方法可以通过goroutines或Faktory来安排？
浏览 18提问于2019-08-27得票数 0
kafka服务器配置了一个跟在端口号后面的路径(来自server.properties)java生产者代码：如果代理省略/kafka，则生产者填充主题
当代理包含/kafa时，生产者获得numberF
浏览 0提问于2014-04-16得票数 0
我已经看到了文档的这一部分()：
$ bin/kafka-topics.sh -创建--动物园管理员本地主机:2181-复制-因子1-分区1-主题测试$ bin/kafka-topics.sh -列表-动物园管理员本地主机:2181测试
或者，也可以将您的代理配置为在向不存在的主题发布时自
浏览 1提问于2018-12-28得票数 1
当我试图从DB2数据库中读取大量数据，并写入Kafka主题时，获取此错误-？继续强制关闭生产者，因为挂起的请求无法在超时30000毫秒内完成。如何增加超时时间？
浏览 35提问于2020-10-16得票数 0
但是，虽然我有这个错误，但我可以使用Kafka工具列出主题，而无法工作：下面是python程序的错误：
from kafka import K
浏览 0提问于2019-02-20得票数 4
在试图将消息推入不存在的kafka主题时，kafka客户端一直在生成以下日志消息：ProducerConfig values: acks = 1 connections.max.idle.ms =
浏览 1提问于2021-09-29得票数 3
1回答
我在Windows 10上安装了Docker，也安装了Kafka。我在一个卡夫卡集群中创建了一个“测试”主题。现在，我想用一个简单的用户名和密码来保护这个主题。我是卡夫卡的新手，任何帮助都会很感激。为了运行Kafka命令，我使用了windows "Power Shell“。
我试过在命令行上运行一些命令。To create Topics:- kafka主题创建-主题测试-分区1-复制因子1-如果不存在-动物园管理员:2181
浏览 2提问于2019-10-23得票数 0
我目前正在使用Nodejs和Kafka，根据这两种方法，可以设置一个Nodejs服务器来接收事件，并将与事件相对应的数据发送给Kafka。在卡夫卡中，如果主题不存在，生产者就会相应地、动态地创建一个主题。要做到这一点，我想在创建之前检查主题的存在与否。在网上搜索时，我找到了<em
浏览 1提问于2016-06-22得票数 5
回答已采纳
2回答
我必须在我的应用程序中定义主题。我使用来配置应用程序之间的消息传递。春云流在背景中采用卡夫卡粘合剂。我想知道用分区和复制因子创建主题的最好方法是什么，我想知道我们是应该配置它本身，还是应该使用application.properties。如果分区号可以是一个依赖于使用者编号的动态值，那该怎么办？
浏览 5提问于2022-06-29得票数 0
回答已采纳
使用哪个Kafka生产者属性来实现以下目标？
我使用的是，它将消息从UDP端口发送到Kafka主题。如果Kafka生产者的内存超过特定的MB (比如300MB)，则丢弃所有消息(无需重试)，并在生产者内存停机时再次恢复接收消息。基本上，如果Kafka broker不能接收任何消息，我会试图使我的服务器免于崩溃。
浏览 3提问于2018-08-29得票数 2
至少一次语义学:如果生产者收到一个确认(ack)从卡夫卡经纪人和acks=all，这意味着消息已经写了一次准确的卡夫卡主题。然而，如果生产者超时或收到错误，它可能会重试发送消息，假设消息没有写到Kafka主题。如果代理在发送ack之前就失败了，但是在消息成功地写入了Kafka主题之后，这个重试将导致消息被写入两次，从而不止一次地传递给最终的使用者。
我知道时间戳是根据从生产者发送消息的时间来设置的。
浏览 2提问于2020-07-18得票数 1
回答已采纳
我开始为Kafka使用汇合的.NET库，并尝试实现一种用于针对Azure服务总线的模式，以便在生产者应用程序启动时创建主题(如果不存在创建)。在卡夫卡API中如何做到这一点，它能做到吗？这将允许主题成为源代码管理的一部分，并在自动发布过程中进行配置，而不是在每个主题/环境中手动设置。此外，我希望我的开发人员不必先访问每个Kafka实例/环境，然后配置它们才能匹配它们。如果我不能这样做，我将不得不在发布过程中将其烘焙
浏览 5提问于2020-10-27得票数 1
回答已采纳
my-replicated-topickafka/bin/kafka-topics.sh --describe --zookeeper 192.168.10.2:2181如果我现在试图通过制片人发送信息：
kafka/bin/kafka-console-producer.sh --broker-list 192.168.10.101:9092,192.168.10.102(org.apache.kafka<
浏览 2提问于2017-12-28得票数 0
来自我的kafka生产者的一些消息超过了默认的1MB，并且被代理拒绝。
我无法访问代理和消费者来进行更改。因此，我只需要在生产者级别进行更改。
浏览 0提问于2020-07-23得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
