オフセット値の増加を防ぎcamus、常に前の値を読み取るようにする方法はありますか?
また、一般的な形式の代わりに作成されるファイルにカスタム名を付ける方法はtopic.leaderId.partitionId.partitioner.encodePartition(context, key)?
質問する
240 次
オフセット値の増加を防ぎcamus、常に前の値を読み取るようにする方法はありますか?
また、一般的な形式の代わりに作成されるファイルにカスタム名を付ける方法はtopic.leaderId.partitionId.partitioner.encodePartition(context, key)?