在Pulsar producer上使用`SendAsync`方法时收到‘收到消息的意外发送回执’警告
是由于消息发送过程中出现了异常情况，导致消息的发送状态与预期不符。这个警告通常是由于以下几种情况引起的：
- 网络异常：可能是由于网络连接不稳定或者网络延迟较高导致消息发送失败或者发送延迟较大，从而引发了警告。
- Pulsar集群故障：可能是由于Pulsar集群中的某个组件出现故障，导致消息发送失败或者发送延迟较大，从而引发了警告。
- Producer配置错误：可能是由于Producer的配置错误，比如设置了错误的发送超时时间或者错误的消息发送模式，导致消息发送失败或者发送延迟较大，从而引发了警告。
针对这个警告，可以采取以下几个步骤进行排查和解决：
- 检查网络连接：确保网络连接稳定，并且网络延迟较低。可以通过ping命令或者网络诊断工具来检查网络连接情况。
- 检查Pulsar集群状态：使用Pulsar的管理工具或者命令行工具来检查Pulsar集群的状态，确保集群中的所有组件正常运行。
- 检查Producer配置：仔细检查Producer的配置，确保发送超时时间和消息发送模式等参数设置正确。可以参考Pulsar官方文档或者相关的开发文档来了解正确的配置方式。
如果以上步骤都没有解决问题，可以尝试以下操作：
- 重启Producer：尝试重启Producer，有时候可以解决临时的网络或者配置问题。
- 联系Pulsar技术支持：如果问题仍然存在，可以联系Pulsar的技术支持团队，向他们报告问题并寻求进一步的帮助和支持。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ（Cloud Message Queue），是一种高可靠、高可用、高性能、分布式的消息队列服务，可满足异步通信、流量削峰、解耦、异步处理等需求。CMQ提供了多种消息模型和消息类型，支持多种编程语言和开发框架，适用于各种场景的消息通信需求。
产品介绍链接地址：腾讯云消息队列 CMQ
相关·内容
我有一个Pulsar主题，我正在通过多个生产者发布消息。这些生产者只是Got unexpected send receipt for message例程，我在生产者上使用SendAsync方法来发送消息，但我一直收到goroutine警告。我查看了客户端的库代码(Pulsar的golang客户端)，发现只有当生产者没有注册为此映射map[uint64]ConnectionListener中的侦听器时，才会显示此警告。但是，当生产者没有注册为侦听器时，我如何能够发布？
func benchmarkConcurrentProducers(b *testing.B, pool []pulsar.Pr
浏览 115提问于2020-05-10得票数 0
如中的示例所示
Producer<User> producer = client.newProducer(JSONSchema.of(User.class))
.topic(topic)
.create();
User user = new User(“Tom”, 28);
producer.send(User);
您可以向Java客户端注册生产者和消费者的模式。还提到，其他语言的客户端不支持模式注册。
现在，是否有可能从Python生产者那里发送一条关于Pulsar主题的消息，该主题将由具有注册模式的消费者使用？例如：
processor = PulsarClie
浏览 3提问于2019-10-23得票数 2
回答已采纳
我是(也是MQ系统)的新手。现在，我有个关于Pulsar阅读器的问题。
问题描述：
我启动一个Pulsar实例，然后启动一个使用者，侦听一个主题A，然后启动一个生产者，向主题A发送100条消息，而使用者消耗了这100条消息，消费者订阅的积压值是0。这个主题上只有一个订阅，而且它是排他的。
在那之后，我启动了一个阅读器，设置读者的主题是A，读者可以从主题A得到混乱。
我在脉冲星博士上发现了这个：
脉冲星代理负责处理通过Pulsar的消息，包括持久存储消息。默认情况下，经纪人：
立即删除在每次订阅中确认的所有邮件，
并将所有未确认的消息持久存储在待办事项中。
这100条消息应该已经删除。那
浏览 2提问于2019-11-21得票数 0
我正在尝试使用Apache Pulsar的重复数据删除功能。 standalone.conf文件中设置了brokerDeduplicationEnabled=true，但是当我从生产者多次发送相同的消息时，我在消费者端得到了所有的消息，这是预期的行为吗？ 重复数据删除不就是AWS SQS中的content based deduplication吗？ 下面是我的生产者代码以供参考。 import pulsar
import json
client = pulsar.Client('pulsar://localhost:6650')
producer = cli
浏览 73提问于2021-08-18得票数 1
回答已采纳
1回答
我正在尝试将Apache设置为log4j2的一个附录。这里没有太多的文档，但是我在这里找到了一些例子。
我已经建立了一个玩具示例，在这个示例中，生产者正在记录单个消息，并且在Pulsar服务器上订阅了同一个主题并侦听消息。消费者收到了一些东西，但没有收到我所期望的信息：
Message sent: Test message
Message received: 18:05:27.510 [pulsar-client-io-5-1] INFO org.apache.pulsar.client.impl.ConsumerImpl
Message received: 18:05:27.510 [ma
浏览 5提问于2020-06-24得票数 3
回答已采纳
生产者：
# 新增一个生产者（单个client下可以创建多个生产者，请尽量复用）
producer = mq_client.create_producer('persistent://pulsar-kxxxx/dev/test')
for i in range(10):
producer.send(('Message-%d' % i).encode('utf-8'), deliver_at=int(datetime.timestamp(datetime.now() + timedelta(seconds=10))*1000))
# 关闭客
浏览 219提问于2021-11-21
2回答
我目前在一个本地Minikube实例上运行Pulsar。我正在尝试连接到该实例并使用Python创建一个生产者。在我安装/启动Pulsar之后，我得到了以下连接信息：
|-----------|-------------------|-------------|---------------------------|
| NAMESPACE | NAME | TARGET PORT | URL |
|-----------|-------------------|-------------|-----------------
浏览 14提问于2021-10-24得票数 1
为了进行测试，我设法运行了一个嵌入式独立pulsar服务器和客户端。我还可以发送和接收消息。然而，我实际上想(集成-)测试功能(实现org.apache.pulsar.functions.api.Function)。如何在嵌入式设置中注册函数？ package kic.data.stream.pulsar
import groovy.util.logging.Log
import org.apache.pulsar.PulsarStandalone
import org.apache.pulsar.PulsarStandaloneBuilder
import org.apache.puls
浏览 26提问于2019-06-09得票数 1
回答已采纳
我对Pulsar还不熟悉，我只是在探索一个新项目的功能。我正在尝试一个非常基本的例子，根据模式从生产者发送数据。为了给出一些背景，我的想法是将数据从apache发送到Clickhouse数据库。我已经完成了接收器连接器的设置，并使用下面的命令验证了相同的设置。
bin/pulsar-admin接收器状态--租户公共名称空间默认名称jdbc-clickhouse-接收器
bin/pulsar-admin接收器列表--租户公共名称空间默认输出：“jdbc-clickhouse-接收器”
所以我在Clickhouse DB中创建了一个表。我希望将数据发送到一个应该保存在数据库中的主题。在这样做的过程
浏览 8提问于2022-02-11得票数 3
1回答
我的情况是，我在Pulsar ()中压缩了主题。通过producer，我使用key发送消息。是否可以通过对consumer使用key来获取特定的消息？
我的代码：
Producer<byte[]> producer = client.newProducer()
.topic(TOPIC_NAME)
.compressionType(CompressionType.LZ4).create();
String name = "name";
String lastName = "lastname&#
浏览 12提问于2020-05-19得票数 1
我正在尝试使用Apache Pulsar进行端到端加密。到目前为止，我看到的示例看起来类似于http://pulsar.apache.org/docs/en/security-encryption/ 我在密钥轮换部分看到每4小时获取一次加密密钥(公钥/私钥)。这似乎表明您只能使用单个密钥来加密您发送的消息。 我希望能够对不同的主题/租户使用不同的加密密钥。pulsar是否支持针对不同主题的不同加密密钥？ 基本上，我的客户端将根据数据所属的租户提取不同的密钥，并使用pulsar的端到端加密来加密与该特定密钥相关的任何消息。 这看起来会怎么样？ 当我想要使用不同的密钥进行加密时，是否就像创建一个
浏览 24提问于2020-07-15得票数 0
在我的例子中，我有一些原始的JSON字符串数据发送到主题，并且不能对POJO类进行硬编码，我想使用pulsar模式功能来验证结构。我在下面有一个主题"my- topic“，并与JSON schema相关联，然后我尝试传输一些消息。 var producer = client.newProducer(Schema.AUTO_PRODUCE_BYTES();
producer.send("{\"y\": 1}".getBytes()); // here! the value is 1(number) not string.
var reader = cl
浏览 38提问于2020-03-22得票数 1
我正在尝试复制struct/SchemaDefinition.下的示例我希望将消息的架构定义为一个名为Davis的类，定义如下：
package com.example.streaming;
import lombok.Builder;
import lombok.AllArgsConstructor;
import lombok.NoArgsConstructor;
import java.sql.Timestamp;
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class Davis {
Timestamp t
浏览 3提问于2021-09-28得票数 1
回答已采纳
我有一个Producer，它使用Apache作为Log4j2的一个附录来记录消息。
Consumer正在监听同一个Pulsar主题，并将接收到的消息写入日志文件。Consumer能够正确地接收消息，但问题是它也在用它记录其他内容：
[localhost/127.0.0.1:6650] Received cmd LOOKUP_RESPONSE
Received Broker lookup response: Connect
[coinflex_logs][coinflex_logs_sub] Subscribing to topic on cnx [id: 0xb78fd850, L:/127.
浏览 1提问于2020-06-26得票数 0
使用Kafka，我可以指定要开始消费的整数消息id和要停止的结束消息，例如：
kafkacat -b kafka:9092 -t messages -o 11000 -c 11333
但是，在Apache中，指定整数开始和停止消息的功能似乎是不可用的！
公平地说，如果已经以字节格式跟踪并保存了开始消息id和结束消息id，则可以使用一个非常复杂的进程来指定它们，这必然会影响性能和代码复杂性。
如本例所示：
client, err := NewClient(pulsar.ClientOptions{
URL: lookupURL,
})
if err != nil {
log.
浏览 2提问于2022-02-08得票数 0
当在码头中作为独立运行Pulsar时，当在特定情况下反序列化消息时，我们将面临这个奇怪的问题。我们使用的是2.7.1版本。
我们有一个创建主题和函数的脚本，然后用JSON类型为麻烦的主题创建模式。整个架构是正确的，但类型不正确。这都是在发送任何信息之前。我们还启用了set-is-allow-auto-update-schema。
我们称它为trouble-topic，它由两个来源填充：ValidationFunction和Spring微服务。
ValidationFunction验证消息，如果消息是有效的，则将映射的消息发送到Spring微服务使用的主题，然后由Spring微服务对其执行一些逻
浏览 8提问于2021-10-21得票数 1
回答已采纳
假设我有一个publisher应用程序，它运行并发布了20条消息，然后就关闭了。
import org.apache.pulsar.client.api.Producer;
import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.client.api.PulsarClientException;
public class TestPub {
public static void main(String[] args) throws PulsarClientException, Interru
浏览 4提问于2022-03-02得票数 1
我正在使用Apache、RabbitMQ和Apache进行一些测试，使用C#客户端库。今晚，我开始对Apache的消息生成器进行一些测试，并且使用官方的.net库(DotPulsar)，我发现与其他消息相比，消息的发送非常慢。似乎不可能脉冲星比卡夫卡和RabbitMQ慢得多，我不知道我是不是做错了什么。我刚写到：
const string myTopic = "persistent://public/default/mytopic";
await using var client = PulsarClient.Builder()
.ServiceU
浏览 5提问于2022-04-18得票数 1
我试图通过java执行apache pulsar生产者和消费者程序，我在GCP虚拟机上安装了apache-pulsar standalone，并在独立模式下启动了集群。下一步是我已经在windows eclipse中给出了一个maven build和我在GCP机器上上传的同一个jar文件，当我在windows eclipse中执行生产者和消费者程序时，我得到了连接被拒绝的错误，这是显而易见的，因为pulsar没有安装在windows机器上。但是，当我在GCP实例中尝试同样的事情时，即使集群已经启动，我也得到了错误，这与没有找到类定义错误有关。 pom.xml >>> <
浏览 344提问于2019-02-10得票数 1
下面的代码向azure EventHub发送消息，一开始很好
public async Task SendMessage(string message) {
var producer = new EventHubProducerClient(this.connectionString, this.eventHubName);
using (EventDataBatch eventBatch = await producer.CreateBatchAsync()) {
if (!eventBatch.TryAdd(new Even
浏览 7提问于2022-07-26得票数 0
我配置了broker.conf并尝试创建一个启用了tls的客户机。实际上，我提供了correctly.It在尝试运行客户端时显示的以下错误的证书路径。
2019-09-27 13:30:36.586 INFO ConnectionPool:72 | Created connection for pulsar+ssl://broker.example.com:6651/
2019-09-27 13:30:36.605 ERROR ClientConnection:441 | [<none> -> pulsar+ssl://broker.example.com:6651/]
浏览 5提问于2019-09-27得票数 1
我有一个Java客户端客户端正在接收Pulsar (v2.10.0) AVRO消息(雇员)，如下所示：
import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.Message;
import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.client.api.PulsarClientException;
import org.apache.pulsar.client.api.Schema;
impo
浏览 2提问于2022-05-31得票数 2
我们有mqtt生产者和消费者。MQTT生成器位于客户端级。当我们向producer推送消息时，如果设备打开了，那么它就会收到消息。如果设备被关闭，那么它在打开之前不会收到消息。
我们需要知道，当消息发送到服务器中的MQTT时，如果服务器关闭了，那么我们需要知道它的状态是，它是否正在排队或未被服务器接收。
在此基础上，我们将向用户as发送消息，请打开设备进行具体操作。
有没有更好的方法来了解MQTT中的状态，以查找消息是否已发送、失败或排队以了解服务器是否处于活动状态。
浏览 0提问于2020-06-04得票数 0
我们团队中有一个新的开发人员，要求她为Docker中的Apache集群构建一个Python客户端概念的简单证明。
让我感到困惑的是，她在哪里没有包括安装python包要求的步骤。通常，我总是有一个Dockerfile，其行如下：
# Install pip requirements
COPY requirements.txt .
RUN python -m pip install -r requirements.txt
不过，她只有一个docker-compose.yml文件，看起来如下：
version: "3"
services:
pulsar:
image:
浏览 7提问于2022-02-10得票数 1
在将卡夫卡版本从2.5.1升级到3.2.0后，遇到了一个令人费解的问题。
我发送信息给卡夫卡制片人如下所示。
final ProducerRecord<String, String> producerRecord = new ProducerRecord<>(
"my_topic",
this.toString()
);
Future<RecordMetadata> kafkaResponse = producer.send(producerRecord);
// producer.flush();
String kafkaSuc
浏览 2提问于2022-07-19得票数 0
回答已采纳
我不能得到一个简单的hello-world类型的Spring Boot应用程序来利用Pulsar Log4j2附加器。在启动时，它会报告错误：
2021-05-14T15:34:23.549-05:00 pulsar-client-io-6-1错误pulsar -client-io-6-1错误o.a.p.c.i.ProducerImpl applog-json无法创建生产者:名为'pulsar-log4j2-appender-applog-json‘的Producer已连接到主题2021-05-14 15:34:23,550主错误无法启动pulsar管理器pulsar manager
浏览 3提问于2021-05-15得票数 1
我在一个apache pulsar集群上工作，它工作得很好，但由于某种原因，当我尝试发送消息时，我开始收到以下消息：
ERROR [id: 0xc5de4911, L:/127.0.0.1:55672 - R:localhost/127.0.0.1:6650] Close connection becaues received internal-server error java.lang.IllegalArgumentException: bound must be positive
另外，我还收到以下错误：
persistent://global/mycluster-cluster1/ns
浏览 19提问于2019-07-22得票数 0
回答已采纳
我正在尝试运行新的apache脉冲星Lakehouse Sink Connector，并获得java.lang.IllegalArgumentException。
下面是我的设置。docker-compose.yaml文件：
version: '3.7'
volumes:
mssql-data:
minio-data:
networks:
oentity:
driver: bridge
services:
pulsar:
image: apachepulsar/pulsar:latest
command: bin/pulsar stand
浏览 19提问于2022-09-20得票数 1
回答已采纳
3回答
Producer创建一个新消息，consumer通过Broker监听它们。
到目前为止，producer在consumer等待消息时创建并发送消息。当新消息出现时，consumer会将其打印到屏幕上。
我希望Producer得到通知，Consumer已经收到消息并将其退出队列。
我想知道有什么办法从Producer通知/反馈Consumer吗？或者我应该通过Consumer通过Broker通知吗？怎么能做到呢？
浏览 7提问于2016-11-07得票数 1
回答已采纳
如何使用Akka Streams持续使用Apache Pulsar中的消息并打印每条消息？
下面是我从库中找到的示例代码。如何打印消费的消息，而不是将消息发布到另一个主题？
val consumerFn = () => client.consumer(ConsumerConfig(Seq(intopic), Subscription("mysub")))
val producerFn = () => client.producer(ProducerConfig(outtopic))
val control = source(consumerFn, Some(Mes
浏览 7提问于2020-05-22得票数 0
以前就发生过这种事情，在短信成功接收的情况下，关于短信下发的回执信息，有部分能接收到，有部分接收不到，一开始以为30s一次调用它的PullSmsSendStatus 频率高了，但是 放到1分钟一次，也不行。依旧是部分短信的回执消息可以接收到，部分接收不到
早上：发送6条成功的短信，其中有3条短信回执消息没有接收到
22.jpg
浏览 292提问于2020-05-20
4回答
我有一个maven项目()，我想在上面运行代码覆盖率。
我在主项目的pom文件上运行了命令mvn test -Pcoverage jacoco:prepare-agent jacoco:report，但是没有生成报告。相反，我收到一个警告说
[INFO] --- jacoco-maven-plugin:0.7.7.201606060606:report (post-test) @ pulsar-discovery-service ---
[INFO] Skipping JaCoCo execution due to missing execution data file.
[INFO]
[I
浏览 1提问于2017-04-20得票数 3
4回答
是否可以检查您的邮件或sms的收件人中有多少人成功地收到了您发送的消息？例如，我将发送一条短信给5个人，但实际上只有3个人收到了这条消息，我如何通过编程来确定实际收到我的消息的收件人的数量？请帮帮我..。我真的受够了..。
浏览 0提问于2012-02-01得票数 0
回答已采纳
我有一个LucidWorksFusion5 kubernetes安装安装在AWS 上，目前该服务之一，连接器经典REST服务，正在经历一次中断。在深入挖掘日志之后，我发现：
ERROR in com.lucidworks.logging.logback.PulsarAppender[PULSAR] - Failed to connect to Pulsar topic persistent://uat/_logs/system_logs at: pulsar://uat-pulsar-broker:6650 org.apache.pulsar.client.api.PulsarClientEx
浏览 9提问于2022-01-07得票数 0
回答已采纳
我正在试图找到一个解决方案，以确保在发送另一个之前，已经收到了对我的Chrome扩展的推送通知。如果它还没有收到，我会修改它的内容，告诉用户他有多个新的信息要检查。
因此，我正在寻找一种方法，在发送新的消息之前，使用其ID检查以前的消息状态，或者如果使用折叠密钥，则检查消息队列。但我找不到与此相关的任何内容，除了这里：有详细的FCM消息状态，但无法在第一次响应后获取它们。
我知道receipts可以使用实现，但我真的更喜欢使用常规的HTTP协议。
感谢您的帮助。
浏览 5提问于2016-08-01得票数 0
回答已采纳
在我的Pulsar消费者/生产者中，当我试图连接到Pulsar时，我会收到以下错误消息：
org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException： java.util.concurrent.CompletionException: org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(.)失败:连接被拒绝: puls
浏览 1提问于2020-06-11得票数 0
我正在尝试为Apache Pulsar设置一个异步消费者，但我的问题是只收到一条消息，除非我重新启动Spring Boot应用程序，否则没有其他消息。不幸的是，关于在脉冲星上使用CompletableFuture的文档不是很好，我还是个新手。 我的代码如下： @EventListener(ApplicationReadyEvent.class)
public void subscribe() throws PulsarClientException {
Consumer consumer = this.pulsarClient.newConsumer(JSONSchema.of(Tenan
浏览 111提问于2021-04-20得票数 1
回答已采纳
我正在尝试实现一个简单的Apache函数，并以LocalRunner模式访问State，但它不起作用。
pom.xml片段
<dependencies>
<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-original</artifactId>
<version>2.9.1</version>
</dependency>
<depend
浏览 8提问于2022-01-07得票数 1
回答已采纳
我正在通过smack使用xmpp。我有连接到A1并通过C1消息发送的连接C1。
假设我已经通过C1发送了100条消息(从我的服务器到我的客户端的下行消息)，确认它们并等待收到通知我消息已经到达设备。我收到了90张收据，但有10台设备没有回复我。
现在我需要重新启动我的get应用程序并关闭C1，我如何在服务器上重新连接到这个C1才能获得这10张收据？
浏览 1提问于2015-12-03得票数 0
在Pulsar Python客户端中，有订阅者选项unacked_messages_timeout_ms来设置未确认消息重新发送的时间间隔。 与Pulsar Go客户端相当的是什么？ Python py_consumer = client.subscribe(
topic='my-topic',
subscription_name="py-subscriber",
unacked_messages_timeout_ms=10000,
consumer_type=pulsar.ConsumerType.Shared
) 戈
浏览 43提问于2021-08-31得票数 0
回答已采纳
1回答
我试图将SignalR用于AspNetCore2.1，以发送来自控制器方法的消息，该方法是从角度上的测试按钮触发的。
我所期望的行为是，当我单击按钮时，我的服务调用控制器方法，该方法发送测试消息。然后，我将简单地记录消息。
我想在服务中管理这一点，以避免所有组件中的代码重复。
我读过一些示例，如 (我使用了第二个解决方案)、和，但是即使应用了这些概念，它似乎也不起作用。
(所以，或者我用错了方法，或者仍然缺少一些东西，但我不知道是什么.)
客户机成功地连接到消息集线器，如果我单击该按钮，则方法将被击中，但没有收到任何消息，而是在Chrome控制台中得到以下警告：
警告:没有找到名为“Send
浏览 2提问于2018-05-30得票数 6
回答已采纳
我正在研究SignalR微软教程中的定位。
一切正常，不过，我想尝试更改ChatHub#SendMessage中的代码，以便向特定用户发送消息。
所以我对代码做了如下修改：
public class ChatHub : Hub
{
public async Task SendMessage(string user, string message)
{
//await Clients.All.SendAsync("ReceiveMessage", user, message);
await Clients.User(user).S
浏览 5提问于2020-08-07得票数 1
回答已采纳
我在学习Spring，我选择聊天应用程序作为我的训练应用程序。我希望尽可能好地实现，以学习好的实践。
现在，我想实现消息的发送和接收。可以使用websocket，但我还希望接收发送消息响应，以向客户端显示其消息是否已发送。(类似于信使)
在spring中使用纯websocket可以做到这一点吗?还是应该使用websocket进行整个通信(发送和接收)？
此外，我希望以后实现其他东西，如发送文件，获得一些数据，如聊天历史记录等。上面也有同样的问题。我是应该使用一个websocket连接，还是只为了一个目的使用websocket通道，例如聊天，以及其他不需要与rest进行实时通信的stufs？优点
浏览 0提问于2018-09-25得票数 1
我们的Apache kafka环境有1- zk，3-服务器。每台服务器上的堆大小为1800 MB。我正在尝试产生1000，20mb的文件来看看Kafka的性能。
我收到: PDT 2015-03-23 13:53:50选择器警告I/O时出现错误，主机位于org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:62)，位于org.apache.kafka.common.network.Selector.poll(Selector.java:248)，位于org.apache.kafka.clients
浏览 1提问于2015-03-24得票数 3
我正在创建一个C#程序，它使用ActiveMQ发送消息，如下所示：
IConnectionFactory factory = new ConnectionFactory("activemq:tcp://localhost:61616");
connection = (Connection)factory.CreateConnection();
connection.Start();
session = connection.CreateSession();
producer = session.CreateProducer(new ActiveMQTopic("topi
浏览 7提问于2019-10-02得票数 0
回答已采纳
1回答
我目前正致力于在Minikube中安装Pulsar。安装似乎进行得很顺利，但是最后当我尝试获取HTTP代理URL和二进制代理URL时...我收到一条错误消息，指出我没有指定有效的服务： xyz-MBP:pulsar xyz$ kubectl get services -n pulsar | grep pulsar-mini-proxy
pulsar-mini-proxy LoadBalancer 10.107.193.52 <pending> 80:31241/TCP,6650:32025/TCP 8h
xyz-MBP:
浏览 36提问于2021-10-19得票数 0
回答已采纳
我的春季批处理在读取步骤中从DB读取数百万行，并在写入步骤中将其发布到kafka主题。
在我正在工作的公司中，我们在kafka上使用一个包装器，我目前正在调用一个sendAsync()方法，该方法接受eventSupplier中的消息和回调: org.apache.kafka.clients.producer.Callback
我的问题是，由于它是一个批处理，我担心作业执行将在我得到异步模式下发送的所有消息的指示之前结束。(可能在最后的msgs上抛出了异常)
是否有弹簧批处理平台支持的方式，以确保步骤完成？还是应该在写步骤中实现Future.isDone()？我在春季批处理文档中看到，在我的情
浏览 11提问于2022-03-30得票数 0
回答已采纳
如果您使用SendAsync(...)将消息发送到Azure服务总线主题/队列消息排序是否有保证？
例如，如果我有一个具有一个线程的应用程序，该应用程序使用SendAsync发送大量消息，那么调用SendAsync方法的顺序是否会保持不变？Service Bus客户端库是否足够智能，能够知道尽管消息将异步发送，但它们添加到主题的顺序在整个过程中都保持不变？
浏览 0提问于2015-01-24得票数 1
1回答
我有两份申请如下：
Spring引导应用程序-充当rest端点，将请求发布到消息队列。(阿帕奇脉冲星)
Heron (Storm)拓扑--处理从消息队列( PULSAR )接收的消息，并具有所有处理逻辑。
我的要求是，我需要通过Spring应用程序提供不同的用户查询，Spring引导应用程序将该查询发送到消息队列，并在spout中使用。一旦喷口和螺栓处理请求，一条消息再次发布从螺栓。来自Bolt的响应在Spring (使用者)处理，并回复用户请求。如下图所示：
为了满足相同的请求，我现在缓存延迟结果对象(我为发送到拓扑的每条消息设置了一个reqID，并在内存中维护了一
浏览 0提问于2017-11-04得票数 1
当我尝试将消息发送到Azure Service Bus中的队列时，消息被发送到队列，但无法接收到成功的确认消息。
在调试过程中，我注意到，系统控制在代码中的以下语句处退出
await client.SendAsync(brokeredMessage).ConfigureAwait(false);
我的代码：
string conString = "xxx";
Microsoft.Azure.ServiceBus.QueueClient client = new Microsoft.Azure.ServiceBus.QueueClient(conString, "que
浏览 0提问于2020-10-21得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
