| クラス | 説明 |
|---|---|
| InitialOffsetsFactoryBean | 初期オフセットのリストを解析し、 OffsetManager を初期化するためのマップを作成します。 |
| KafkaConsumerOptionsMixin | Kafka コンシューマー構成のモジュールオプション。 |
| KafkaMessageTransformer | Kafka メッセージをパーティションとペイロードの Map に変換するトランスフォーマー。 |
| KafkaOffsetTopicOptionsMixin | |
| KafkaPartitionAllocator | ストリームにデプロイされた Kafka ソースモジュールの複数のインスタンス間のパーティション割り当てを管理するロールを担います。 |
| KafkaProducerOptionsMixin | Kafka プロデューサー構成のモジュールオプション。 |
| KafkaSinkModuleOptionsMetadata | Kafka シンクモジュールのモジュールオプション。 |
| KafkaSourceModuleOptionsMetadata | Kafka ソースモジュールのモジュールオプション。 |
| KafkaZKOptionMixin | ZK 構成用の Kafka モジュールオプションミックスイン。 |
| NamespaceDelegatingMetadataStore | デリゲート MetadataStore をラップし、処理されるすべてのキーにプレフィックスを追加します。 |
| WindowingOffsetManager | 基礎となるデリゲートを使用して実際の操作を実行し、時間またはカウントウィンドウにわたって書き込みを集約する OffsetManager。 |
| 列挙型 | 説明 |
|---|---|
| AutoOffsetResetStrategy | Kafka クライアントのオフセットを自動的にリセットするための可能な値 |
| KafkaSourceModuleOptionsMetadata.OffsetStorageStrategy |