私は現在、Golang版でシンプルなKinesis Client Library(KCL)を作成しています。私が私の単純なKCLに求めている機能の1つは、複数のレコードプロセッサとEC2インスタンスにわたるシャードのロードバランシングです。たとえば、私は別のEC2インスタンスで動作する2つのレコードプロセッサと4つのKinesisシャードを持っています。負荷分散機能により、各レコードプロセッサはキネシスシャードを処理できます。いくつかのレコードプロセッサでキネシスシャードのバランスをとるにはどうすればいいですか?
Java KCLはこれを実装していますが、ライブラリの実装が見つかりません。私の質問は、Golangでこの機能を実装する方法です。ありがとうございました。
あなたが持っている別のオプションは次のとおりです。すでにこれを行っている何人かの人々があるように見える
リソースありがとう、Ryan。しかし、あなたはここで私の質問に答えなかった。 –