input {
  jdbc {
    jdbc_driver_library => "D:\elastic\logstash\mysql-connector-j-9.0.0.jar"
    jdbc_driver_class => "com.mysql.cj.jdbc.Driver"
    jdbc_connection_string => "jdbc:mysql://esghosts.com:3306/esgsadmin_eturk"
    jdbc_user => "esgsadmin_eturk"
    jdbc_password => "p4kc7bzcnxsz"
    schedule => "* * * * *"
    statement => "select flash_deals.id as flash_deals_id,flash_deals.title as flash_deals_title,flash_deals.start_date as flash_deals_start_date,flash_deals.end_date as flash_deals_end_date,flash_deals.status as flash_deals_status,flash_deals.featured as flash_deals_featured,flash_deals.background_color as flash_deals_background_color,flash_deals.text_color as flash_deals_text_color,flash_deals.banner as flash_deals_banner,flash_deals.slug as flash_deals_slug,flash_deals.created_at as flash_deals_created_at,flash_deals.updated_at as flash_deals_updated_at from flash_deals "
    use_column_value => true
    tracking_column => "select flash_deals.id as flash_deals_id,flash_deals.title as flash_deals_title,flash_deals.start_date as flash_deals_start_date,flash_deals.end_date as flash_deals_end_date,flash_deals.status as flash_deals_status,flash_deals.featured as flash_deals_featured,flash_deals.background_color as flash_deals_background_color,flash_deals.text_color as flash_deals_text_color,flash_deals.banner as flash_deals_banner,flash_deals.slug as flash_deals_slug,flash_deals.created_at as flash_deals_created_at,flash_deals.updated_at as flash_deals_updated_at from flash_deals _id"
    jdbc_paging_enabled => "true"
    jdbc_page_size => 10000
  }
}
 filter {
 

    mutate  {
          
          rename=>  {
          
            }
    }
}

output {
  elasticsearch {
     hosts => "localhost:9200"
     index => "flash_deals"
     user => "elastic"
     password => "123456"
     document_id => "%{flash_deals_id}"
     ssl_enabled => true
     ssl_verification_mode => "none"
  }

}