ストリーミング

Flink パイプラインの出力パーティション数にデフォルト値はありますか？また、設定できますか？

パーティション数を自動計算する場合、出力はデフォルトで8パーティションに制限されますが、パイプライン設定で最大16パーティションに設定できます。

タイムスタンプ： 2024年3月2日

Kafka にエクスポートするためにバッチデータセットをストリームに変換する際のベストプラクティスは何ですか？

ベストプラクティスは、Pipeline Builder でストリーミングパイプラインを作成し、バッチデータセットを入力として使用して、出力をストリームとして設定することです。その後、通常の Kafka ストリーミングエクスポートのドキュメントに従って、このストリームを Kafka にエクスポートできます。

タイムスタンプ： 2024年3月26日

Java デプロイメントの UDF からストリームをリプレイするにはどうすればよいですか？

パイプライン設定の yaml ファイルでロジックのバージョンを上げると、ストリームをリプレイできます。

タイムスタンプ： 2024年7月25日