@KafkaHandler(isDefault = true)处理消息时，无法获取正确的接收主题

文章/答案/技术大牛

发布

1回答

spring-kafka

我想要获取其他KafkaHandler无法识别其有效负载的消息的主题。public void fooMethod(Foo foo) {} public void barMethod(Bar bar) {} public void unknownObjectMethod( @Header(KafkaHe

浏览 73提问于2020-05-07得票数 0

回答已采纳

1回答

用Spring从同一个Kafka主题反序列化不同的JSON有效载荷

java、json、spring-boot、apache-kafka、spring-kafka

我试图从同一个Kafka主题反序列化不同的JSON有效负载。这里提出的其他问题，引导我进行了第一次尝试，但我无法使它运行。正如加里提到的()，有一些提示(JsonSerializer.ADD_TYPE_INFO_HEADERS)，但是当我发送和接收这两条消息时，我会得到一个异常。LoggingErrorHandler已经在ConsumerRecord中提到了一个(正确的)值。isReadOnly = false),

浏览 0提问于2019-01-24得票数 5

回答已采纳

1回答

在一个kafka主题中发布多个事件共享一些属性

spring-boot、apache-kafka

我需要从代表员工旅程事件的同一个项目中发布多条消息，而且我只需要使用一个主题来发布这些消息，因为它们代表着相同的项目，但是在某些情况下，消息可能包含额外的字段，例如：所有的消息都共享(id，name，type，date)，有些事件可能有更多的字段，如(课程id，课程名称)，所以我打算使用一个父对象，称为“旅程”，包含“事件”对象，如果需要的话，我将创建多个子对象，比如扩展此事件的'LMSEvent‘另外，

浏览 11提问于2022-11-17得票数 0

1回答

使用VALUE_TYPE_METHOD的弹簧卡夫卡

spring-boot、spring-kafka

TL/DR -有人能提供一个使用JsonDeserializer.VALUE_TYPE_METHOD的简单例子吗？我有一个与完全匹配的情况：从版本2.5开始，您现在可以通过属性配置反序列化器，以调用方法来确定目标类型。如果存在，这将覆盖上面讨论的任何其他技术。如果数据是由不使用序列化程序的应用程序发布的，并且需要根据数据或其他标头将数据反序列化为不同的类型，则会非常有用。将这些属性设置为方法名称--一个完全限定的类名，后面跟着方法名，由句点分隔。该方法必须

浏览 9提问于2022-10-04得票数 0

1回答

用Spring从单个主题反序列化不同消息(使用共享数据)

java、spring、apache-kafka

TL；博士如何使用@KafkaListener和@KafkaHandler根据属性将一个主题映射到不同的处理程序，映射到具体的对象？我有一个单一的主题，其中包含不同的信息。消息的格式为{type: 2, data2:"bar"} 我最好通过这样的单一侦听器来使用它们。Could not resolv

浏览 7提问于2021-10-13得票数 0

2回答

蔚蓝的服务总线订阅是否像队列？

azure、azureservicebus、servicebus、azure-servicebus-queues、azure-servicebus-topics

这可能是一个愚蠢的问题，但我无法通过阅读文档找到明确的明确答案。因此，假设您有一个队列，您可以向其发送多条消息，并将多个客户机/读取器连接到队列。在这种情况下，每条消息只由一个客户机/读取器接收。现在假设您已经做了一个主题，并向其发送消息。您有几个客户端/阅读器，每个客户端/阅读器都有自己的主题订阅；在这种情况下，每个客户机&

浏览 0提问于2019-12-01得票数 0

回答已采纳

3回答

如何使用Kafka流DSL函数处理重复消息

apache-kafka-streams

我的要求是使用kafka流DSL跳过或避免从输入主题接收的重复消息(具有相同的密钥)。源系统->输入主题-> Kafka流->输出主题目前，我正在使用flatMap来生成多个有效负载密钥，但是flatMap是无状态的，因此在接收到输入主题时<

浏览 1提问于2019-04-23得票数 1

回答已采纳

3回答

Azure服务总线ReceiveBatch()的奇性

c#、azure、azureservicebus

当前使用Azure服务总线主题，并遇到使用ReceiveBatch方法接收消息的问题。问题是，预期的结果实际上并不是我所得到的结果。，然后在第一次运行时进行轮询，我将得到第一条消息。在第二轮比赛中，我得到了其他的3。我期待着同时得到所有的4。它似乎总是在第一次投票中返回一个单数值，然后在随后的投票中返回一个单数值。(第二次尝试发送的n条消息和第一次尝试发送1条消息的</em

浏览 1提问于2015-08-11得票数 11

回答已采纳

1回答

GCM在订阅前发送消息

android、google-cloud-messaging

我刚刚在我的Android应用程序中成功地实现了Google消息传递，为了测试它，我从我的服务器发送了一些消息，这些消息非常有效。我想知道，如果我发送一条消息到一个特定的主题，然后一个设备订阅了这个主题，它会收到消息吗？谢谢

浏览 5提问于2015-11-22得票数 0

回答已采纳

1回答

订阅100 k保留消息的MQTT

mqtt、mosquitto、paho

我们为本主题'devices/access_control/inout_status/by_project/#'.保留了超过100 k条消息订阅后，我们收到大约8k-10k的消息，然后它与错误的‘断管’断开连接，在重新连接后，我们再次收到相同的10k消息。

浏览 0提问于2018-06-12得票数 0

回答已采纳

2回答

解析JSON时无效字符

javascript、json、typescript

我已经将一个对象存储在本地存储中，但是解析该值时出现了一个错误。我不知道错过了什么。我无法更改值，因为它来自数据库。我需要一种正确的方法来处理这个错误，而不是改变字符串值。 ":[{\"Id\":1,\"FunctionName\":\"View COC\",\"Description\":\"View COC information for a version\",\"IsD

浏览 0提问于2018-01-22得票数 0

回答已采纳

1回答

FCM推送服务器主题消息

android、firebase、firebase-cloud-messaging

我正在考虑使用http在我们的推送服务器中应用。我的问题是，当我们将我们的遗产转移到FCM时，有没有办法获得相同的信息？因为topic api似乎没有返回数据。如果存在，我如何<e

浏览 0提问于2017-05-22得票数 1

3回答

与队列相比，只具有一个订阅的蔚蓝服务总线主题的缺点是什么？

azureservicebus、azure-servicebus-queues、azure-servicebus-topics

我目前正在学习Azure Service Bus，我不理解Queue与具有单一订阅的主题相比的真正好处。我发现，在这两种情况下，都可以在侦听单个队列(或订阅)中创建不同的应用程序，以更快地处理消息。那么，如果主题可以以同样的方式工作，那么使用蓝色服务总线的队列有什么真正的方便呢？更好的表现？更便宜吗？

浏览 0提问于2018-09-05得票数 4

1回答

kafka处理器api中的回滚机制？

apache-kafka、apache-kafka-streams

i使用的是卡夫卡处理器api (而不是DSL) { } 场景：我们从源主题读取数据，流处理器将数据写入多个接收器主题(topicList )。问题:当上述中的一个或多个主题无法接收消息时，如何使用

浏览 1提问于2020-06-22得票数 0

回答已采纳

2回答

jms和spring集成的性能问题。以下配置有什么问题？

jms、activemq、messaging、spring-integration

我有一个jms生产者，它每秒生成许多消息，这些消息被发送到amq持久队列，并由单个消费者消费，这需要按顺序处理它们。但似乎生产者比消费者快得多，我有性能和内存问题。获取消息的速度非常慢，消费似乎是按时间间隔进行的(消费者以轮询方式“请求”消息，这很奇怪吗？！) 基本上，所有事情都是通过spring集成来实现的。下面是生产者端的配置。第一批消息来自stakesInMemoryChannel，从那里，它

浏览 0提问于2012-11-21得票数 1

1回答

从服务总线队列接收消息时发出

azure、azure-web-app-service、message-queue、azureservicebus

基于在队列中接收消息的会话id，我有一个分区的服务总线队列。但我得到了以下补偿，请帮助我重新处理这个问题

浏览 3提问于2021-12-02得票数 0

2回答

在服务总线主题中查找重复消息

c#、azureservicebus

我想在ServiceBusTopics.Below中找到重复的消息是我的logic.If，我发现任何重复的消息都要添加到列表中，然后发送到另一个服务总线主题。但是，在循环遍历列表之前，我无法读取订阅中的所有服务总线消息。，我想读取sevicebus中的所有消息，然后循环遍历它。我不知道在读取来自的所有消息之前，应该如何停止循环的执行 pr

浏览 0提问于2019-01-02得票数 0

回答已采纳

2回答

停止spark Streaming上下文kafkaDirectStream

scala、apache-spark、spark-streaming

我想在从kafka topic接收和处理完成后结束流处理。停止不应该像( awaitTerminationOrTimeout )那样特定于时间。有没有办法在主题耗尽后停止sparkstreamingcontext上下文。有没有一种方法可以将DstreamT与T值进行比较来指示控制流？

浏览 3提问于2016-05-03得票数 1

1回答

为什么要用死信队列？

architecture、publish-subscribe、dead-letter

我正在考虑可能为一组服务所使用的队列实现一个死信队列，用于相互通信。接收消息的应用程序没有处理它的能力。在场景1中，

浏览 2提问于2022-02-18得票数 2

回答已采纳

1回答

不断从Azure ServiceBus接收消息

python、azure、asynchronous、azureservicebus、azure-servicebus-topics

根据Azure ServiceBus文档 ServiceBusReceiver类定义了一个高级接口，用于接收来自Azure队列或主题订阅的消息。消息接收的两个主要通道是接收()以发出单个消息请求，以及async for message in receiver:以持续的方式连续接收传入的消息。每次消息出现时，我都试图使用async for mes

浏览 6提问于2021-01-19得票数 4

点击加载更多