sarama

0熱

1答えて

私は、Kafka 0.11クラスターに接続しているGoアプリケーションが古い0.8.2バージョンのライブラリーを使用していたことを知りました。応答にタイムスタンプ値がありません。私はKafka 0.11.x API /バージョンがサポートされていないことを発見しました（しかし、彼らはそれに取り組んでいます）。私は今のところ2つの解決策があります。まず、必要なバージョンを自分のアプリケーション

0熱

1答えて

Docker

にデプロイすると、GolangパニックにApache Kafkaのコンシューマーが実装されました。ここでは、kafkaサーバーからメッセージを読み込んでHTTP経由で送信する単純なマイクロサービスを実装しようとしています。それは私が、端末からそれを実行すると正常に動作しますが、 panic: runtime error: invalid memory address or nil pointer

1熱

1答えて

Golang Kafkaの特定のオフセットからコンシューマを設定する方法10

クラッシュする前に最後に処理したメッセージからプロデューサを開始する必要があります。幸いにも私は1つのトピックと1つのパーティションと1つのコンシューマを持つ場合です。私はhttps://github.com/Shopify/saramaを試しましたが、それはまだ利用可能ではないようです。私は現在、すべてのメッセージオフセットをコミットできるように、https://godoc.org/gith

1熱

1答えて

Golang Kafka 10でGroupIDを取得するには？

私はKafka 10.0とhttps://github.com/Shopify/saramaを使用しています。私は消費者が処理した最新のメッセージのオフセットを取得しようとしています。これを行うには、グループ名が必要なNewOffsetManagerFromClient(group string, client Client)というメソッドが見つかりました。消費者グループ名を取得するにはどう

0熱

1答えて

Golangでカフカコンシューマーグループを作成するには？

利用可能なライブラリはsarama（またはその展開sarama-cluster）ですが、saramaでもsarama-clusterではなく、消費者グループの例は提供されていません。私はAPIを理解していません。トピックのコンシューマ・グループを作成する例がありますか？

0熱

2答えて

新しいトピックがカフカで作成されたことを消費者に通知するには？

消費者に消費量を動的に更新させようとしています。動物を使った具体的な例を挙げておきます。私がペットショップを持っていると想像してみましょう。すべての話題は動物の一種です（犬、猫、魚など）。私のカフカの消費者の主な責任は、私たちがカフカで持っているログ/記録/メッセージを取得し、それらをデータベースに保存することです。私の消費者がdogsとcatsのトピックで積極的に消費していて、すべてうまくい

2熱

1答えて

sarama-clusterでNewConsumerをモックする

実際のブローカーを設定せずにsarama-clusterのNewConsumer関数をテスト/モックする方法はありますか？私はここで何が欠けていますか？私がテストしようとしているコード： import cluster "github.com/bsm/sarama-cluster" func initSaramaConsumer() (*cluster.Consumer, error) {

1熱

1答えて

Golang Saramaパッケージを使用して、ローカルに実行中のKafkaサーバーからのメッセージを使用できません。

私はローカルのKafkaサーバーからメッセージを読み込んでチャットに出力する簡単なテレグラムボットを作っています。 zookeeperとkafkaサーバーの設定ファイルはどちらもデフォルトになっています。コンソールのコンシューマー作品。 Golang Saramaパッケージを使用してコードからメッセージを消費しようとすると、この問題が発生します。私はこれらの行を追加する前に： case err :