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 affiliate_users.id as affiliate_users_id,affiliate_users.paypal_email as affiliate_users_paypal_email,affiliate_users.bank_information as affiliate_users_bank_information,affiliate_users.informations as affiliate_users_informations,affiliate_users.balance as affiliate_users_balance,affiliate_users.status as affiliate_users_status,affiliate_users.created_at as affiliate_users_created_at,affiliate_users.updated_at as affiliate_users_updated_at,users.id as users_id,users.referred_by as users_referred_by,users.provider as users_provider,users.refresh_token as users_refresh_token,users.access_token as users_access_token,users.user_type as users_user_type,users.name as users_name,users.email as users_email,users.email_verified_at as users_email_verified_at,users.verification_code as users_verification_code,users.new_email_verificiation_code as users_new_email_verificiation_code,users.password as users_password,users.remember_token as users_remember_token,users.device_token as users_device_token,users.avatar as users_avatar,users.avatar_original as users_avatar_original,users.address as users_address,users.country as users_country,users.state as users_state,users.city as users_city,users.postal_code as users_postal_code,users.is_influence as users_is_influence,users.phone as users_phone,users.balance as users_balance,users.banned as users_banned,users.referral_code as users_referral_code,users.remaining_uploads as users_remaining_uploads,users.created_at as users_created_at,users.updated_at as users_updated_at,users.can_use_google_translate as users_can_use_google_translate,users.info_update_pending as users_info_update_pending,affiliate_users.created_at as  '@timestamp' from affiliate_users  left join users on users.id=affiliate_users.user_id"
    use_column_value => true
    tracking_column => "affiliate_user_id"
    jdbc_paging_enabled => "true"
    jdbc_page_size => 10000
  }
}
 filter {
 

    mutate  {
          
          rename=>  {
          
            }
    }
}

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

}