問題タブ [spring-kafka]
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.
spring-cloud - 新しいリリース Chelsea.RC1 の「条件パラメーター ヘッダー」@StreamListener の使用エラー
春のクラウド ストリーム (Chelsea.RC1) の新しいリリースで利用可能な新機能を使用して、イベント フィルターを使用して、アプリケーションが使用するトピックの量を削減しようとしています。メッセージは正しいヘッダーで作成されていますが、キュー内のメッセージの内容を検査すると、メッセージにはヘッダーが含まれておらず、ペイロードを含む本文のみが含まれています。
消費者
コンシューマー サービスでは、次の警告が表示されます。
spring-cloud-stream - 未加工のヘッダーを含む null/tombstone メッセージを発行する
私は、Spring Cloud Stream Kafka プロセッサ アプリを構築しています。これは、文字列キーと、場合によっては Kafka トピックからの null ペイロードを使用して生データを消費します。String キーと null ペイロード (Kafka では廃棄 (tombstone) と呼ばれます) を別のトピックに生成したいと考えています。メッセージで生のヘッダーを使用するには、 を出力する必要がありますbyte[]が、 にエンコードKafkaNull.INSTANCEするbyte[]と、文字どおりオブジェクト ハッシュコードの文字列が出力されます。
以外のものを送信しようとするとbyte[]、未加工のヘッダーを使用できません。
これを行う正しい方法は何ですか？ペイロードが null の場合でも、ヘッダーはどこにありますか? 展開を設定producer.headerMode=embeddedHeadersしましたが、違いはないようで、ペイロードとしてハッシュコードがまだあります。
spring - Spring Boot Kafka: NoSuchBeanDefinitionException が原因でコンシューマを起動できません
春のブート サービスでは、kafka コンシューマーを開始しようとして NoSuchBeanDefinitionException が表示され、サービス自体を開始できませんでした。
以下は、Kafka 構成用に作成されたすべての必要な Bean を持つ私の Bean クラスです。
スプリング ブート バージョン: 1.5.2.RELEASE
例外トレースは次のとおりです。