kafka-producer-api

0熱度

1回答

代碼發送Avro的消息到卡夫卡的話題 props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, io.confluent.kafka.serializers.KafkaAvroSerializer.class); props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONF

1熱度

1回答

Kafka Consumer - 收聽方收到的參數恢復方法

我正在建設一個春季卡夫卡消費者。我已經設置了重試機制。重試完畢後，我想將失敗的消息推送給死信主題。 Listen方法具有以下參數 public void listen(@Payload Map<String, Object> conciseMap, @Header(KafkaHeaders.RECEIVED_PARTITION_ID) int partition, Ackn

1熱度

1回答

卡夫卡生產商很慢

我是卡夫卡新手，我有一個問題，我無法解決。我在我自己的計算機中安裝了Kafka和Zookeeper（不在Linux中），並且我創建了一個包含多個分區（在6和12分區之間播放）的主題的代理。當我創建消費者時，他們完美地工作並且以良好的速度閱讀，但是提到生產者，我創建了許多網站中可以看到的簡單生產者。生產者在一個循環內併發送很多短消息（大約2000個非常短的消息）。我可以看到消費者非常quicl

3熱度

1回答

卡夫卡生產TimeoutException異常：到期

我使用卡夫卡與春季啓動1個結果：卡夫卡監製類： @Service public class MyKafkaProducer { @Autowired private KafkaTemplate<String, String> kafkaTemplate; private static Logger LOGGER = LoggerFactory.getLogge

0熱度

1回答

卡夫卡 - 簡單的消費/製造商設置沒有不同的機器上工作，但使用下面的簡單<code>producer</code>/<code>consumer</code>教程本地工作

我已經安裝和設置Kafka： https://kafka.apache.org/quickstart 我有2機器，並且都使用Ubuntu。簡歷的問題：如果我使用producer和consumer在同一臺機器上，一切工作正常。如果我用machine 2的producer，並在machine 1休息，如kafka，zookeeper服務器和consumer，我從來沒有在machine 1收到任何

1熱度

1回答

C++與卡夫卡 - 消費者只得到一些製片人的消息

我用下面的代碼C++產生消息Kafka： #include <thread> #include <cppkafka/producer.h> using namespace cppkafka; int main() { for(int i = 0 ; i < 100 ; i++) { std::cout << "sending msg number: "

3熱度

1回答

Kafka Streams：如何更改記錄時間戳（0.11.0）？

我正在使用FluentD（v.12上一個穩定版本）向Kafka發送消息。但FluentD使用的是舊的KafkaProducer，因此記錄時間戳記始終設置爲-1。因此，我必須使用WallclockTimestampExtractor將記錄的時間戳設置爲時間點，當郵件到達kafka時。時間戳我在真的有興趣，由fluentd消息中發送：「時間戳」：「1507885936」，「主人」：「V.X

0熱度

1回答

Apache Kafka：生產者-Consume API沒有在GCP上運行

我一直試圖在Kafka集羣上運行我的生產者和消費者api，但它不工作。 1）動物園管理員是在一個GCP VM實例運行 2）卡夫卡正在另一個GCP VM實例運行步驟如下：步驟1）使用運行動物園管理員以下命令： bin/zookeeper-server-start.sh config/zookeeper.properties 個Zookeeper.properties： #the direct

1熱度

1回答

不能從Python代碼

產生卡夫卡我有這個模塊運行（所有地方）：的ZooKeeper 卡夫卡服務器卡夫卡消費者 Python腳本在劇本有send()電話： producer = KafkaProducer(bootstrap_servers=['localhost:9092']) producer.send('test', 'entry1') 每15秒左右。卡夫卡服務器上的幾乎每一個send() 調用產生這些

0熱度

1回答

confluent-python kafka生產者發送回調message.offset（）返回0

Producer.send回調提供了一個消息對象。 message.offset()通常在看起來是一個錯誤時返回0。這是用的： confluent-kafka python庫版本0.11.0 librdkafka：stable 0.11.0（瓶裝），HEAD。通過的Mac OS自制下面簡單的測試程序安裝： import confluent_kafka import timeit def