私は既にjdbc
プラグインのinteger
とdatetime
プラグインのフィールドをlogstash
入力に入れてテストしました。これは完全に動作しています。私のテーブル内の任意のdatetime
またはint
フィールドが存在しない場合、私はちょうど骨董だjdbc sql_last_valueにvarchar/stringを使用できますか?
、場合には、時間にsql_last_value
時間を更新するために、フィールドのvarchar/string
タイプを使用してのいずれかの可能性があります。
ご協力いただければ幸いです。
設定ファイルを表示してください。私は同様の問題に直面しています。私のlogstashは整数としてsql_last_valueを使っていますが、古いレコードも読み込みます。私はESで重複レコードを見ることができます。私は.logstash_jdbc_last_runファイルをチェックしました。それには0が入っています。どこが間違っているのか分かりません。私は以下の設定も使用しています。use_column_value => true tracking_column => "SEQ_NO" record_last_run => true –