問題タブ [confluent-kafka-dotnet]

質問する

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

77 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
1 に答える
862 参照

c# - Confluent Kafka Dotnet で失われるメッセージ

最近の c# プロジェクトで Confluent kafka パッケージを使用しています。次の方法でプロデューサーを作成しました。

しかし問題は、私のメッセージの一部が消費者に届いていないことです。彼らはどこかで迷子になっています。ただし、プロデューサーでawaitを使用すると、すべてのメッセージが配信されます。すべてのメッセージを待たずに配信する方法。（私は単一のパーティションを持っています）

0 投票する
1 に答える
271 参照

c# - Autofac C# による依存性注入 - ジェネリック型を登録するときにファクトリ メソッドを指定することは可能ですか

私はDIとAutofacに非常に慣れていません。以下にリストされているように、私はシングルトンクラスを持ってProducerServiceいます。これは、BackgroundService のコンストラクターで依存関係として使用されます。ProducerService には、コンストラクターによって注入された依存関係がIKafkaProducerAggregateあります。これも以下に示します。

IKafkaProducerAggregate<TKey, Tvalue>ProducerService<TKey, TValue> に挿入するために作成される単一のインスタンスを作成するにはどうすればよいですか? IProducerこれには、ファクトリ メソッドを介して、外部の Kafka 合流ドットネット ライブラリからののインスタンスが含まれますIProducer<TKey, TValue> producer = new ProducerBuilder<TKey, TValue>(Config.Producer).Build();。IProducer集計インスタンスを作成し、 Kafka 合流式のファクトリ メソッドを使用して初期化する Autofac で何らかのファクトリ メソッドを使用できますか?

これまでのところ、プロデューサー サービスを登録する Autofac モジュールがあり、ファクトリ メソッドに似たものを使用する方法を理解するのに苦労していますか??? ProducerService の作成時に IKafkaProducerAggregate を作成します。

インターフェース: IKafkaProducerAggregate

クラス: ProducerService


12345678910