spring-kafka

    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
    spring kafka-consumer-api spring-kafka 2017-03-23

    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
    java spring spring-kafka 2017-03-24

    1熱度

    1回答

    添加多個KafkaListenerContainerFactory的問題

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

    0熱度

    1回答

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

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

    0熱度

    1回答

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

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

    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。
    apache-kafka spring-kafka 2017-04-02

    2熱度

    2回答

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

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

    0熱度

    1回答

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

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

    1熱度

    1回答

    SpringXD/Spring集成：使用不同版本的彈簧集成 - 卡夫卡對生產者和消費者

    我有以下配置： Spring的集成 - 卡夫卡1.3.1.RELEASE 我有一個自定義卡夫卡水槽和一個自定義的卡夫卡源 的配置我想有： 我想仍然使用Spring-integration-kafka 1.3.1.RELEASE和我自定義的kafka-sink。 我改變了我的卡夫卡型邏輯使用Spring的集成 - 卡夫卡2.1.0.RELEASE。我注意到實現消費者/生產者的方式與先前版本的Spri
    apache-kafka spring-integration spring-xd spring-kafka 2017-04-04

    2熱度

    1回答

    apache kafka的異常 - 獲取apikey的請求時出錯：3和apiVersion：2

    我對Apache Kafka和Spring Kafka相當陌生，現在正在編寫一個應用程序，它會消耗主題中的信息並執行一些操作。 我寫了一個簡單的使用@KafkaListener註解的消費者，並對我的本地Kafka服務器0.10.1.1進行了測試，它工作得很好。 現在，當我指着我們的卡夫卡的DEV服務器（版本 - 0.10.0.2.5）我看我得在客戶端登錄以下異常： network.Selector
    apache-kafka spring-kafka 2017-04-04
最新問題