spring-kafka

1熱度

1回答

看起來像KakfkaTemplate可以使用泛型來配置以指示鍵和值。特定於用例的密鑰類型是什麼？例如一些標識信息，比如personId，patientId，該值會呈現某種pojo（DTO，可能不是整個JPA實體）這導致了一個問題，我們應該根據用例配置多個KafkaTemplates ）？

1熱度

1回答

錯誤使用「條件參數頭」@StreamListener的新版本Chelsea.RC1

我想使用事件過濾器來減少應用程序使用彈簧雲流新版本中提供的新功能的主題量（ Chelsea.RC1）。消息正在被創建，但具有正確的頭部，但是，檢查隊列中消息的內容，消息不包含頭部，只包含具有有效載荷的主體。 public void sendEnroll(EnrollCommand data) { //MessageChannel outputEnroll.send(Messa

2熱度

2回答

Spring Boot Kafka：由於NoSuchBeanDefinitionException而無法啓動消費者

在我的spring啓動服務中嘗試啓動kafka使用者時發現NoSuchBeanDefinitionException並無法啓動服務本身。下面是我的bean類，它擁有所有卡夫卡配置創建所需的豆類春天引導版本：1.5.2.RELEASE import java.util.HashMap; import java.util.Map; import org.apache.kafka.client

0熱度

1回答

誤差@KafkaListener

我使用spring-kafka具有以下配置的處理： package com.danigu.fancypants.infrastructure; import com.fasterxml.jackson.databind.ObjectMapper; import lombok.Data; import org.apache.kafka.clients.consumer.ConsumerCon

1熱度

1回答

添加多個KafkaListenerContainerFactory的問題

您好我目前正在涉足Spring Kafka，併成功地將一個KafkaListenerContainerFactory添加到我的偵聽器。現在我想添加多個KafkaListenerContainerFactor（一個用於json中的消息，另一個用於字符串的主題）。請參見下面的代碼： @EnableKafka @Configuration public class KafkaConsumersCon

0熱度

1回答

如何更改[kafka-consumer-1]此線程名稱？

我將併發性設置爲10，我可以看到10個不同的線程ID，但線程名稱都是一樣的。如何設置偵聽器名稱？我試過container.setBeanName但沒有運氣。請幫忙。順便說一下，我使用1.1.2版本

0熱度

1回答

如何在使用ConcurrentKafkaListenerContainerFactory時設置主題？

當我使用concurrentKafkaListenerContainerFactory時，有什麼辦法可以設置主題嗎？我根本不想要任何註釋。

2熱度

1回答

kafka-consumer-groups.sh相當於？

我正在使用0.10.2版本。我想知道是否有任何卡夫卡的Java API可以獲取偏移信息如使用： ./bin/kafka-consumer-groups.sh --bootstrap-server 192.168.0.28:9092 --describe --group test 因爲我想告訴所有這一切偏移信息在我的應用程序，而無需使用CLI。

2熱度

2回答

卡夫卡消費方故障處理和重新發送

如果某些消息未在卡夫卡回覆，會發生什麼情況。假設我正在同時使用消息。而且有一位消費者無法處理消息的偏移量= 20，並且沒有發送Ack。但是偏移量= 21的其他消息已被消耗並回復。我怎麼才能重播只有20？我是否需要將消息放入DLQ並再次消耗？如果在那裏發生故障呢？我有點困惑與保證交付。

0熱度

1回答

Spring Boot - 獲取spring.kafka客戶端的application.properties中的主機名

我正在使用Spring-Kafka和Boot開發一個項目，並且希望獲取屬性spring.kafka的application.properties中的主機名。 consumer.client-Id，這樣，如果出現問題，我的每個消費者都可以在服務器端日誌中進行區分。有沒有辦法我能做到這一點？我檢查了spring引用參考指南和java.lang.System類，但找不到有效的指針。