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 refund_request_conversations.id as refund_request_conversations_id,refund_request_conversations.content as refund_request_conversations_content,refund_request_conversations.images as refund_request_conversations_images,refund_request_conversations.created_at as refund_request_conversations_created_at,refund_request_conversations.updated_at as refund_request_conversations_updated_at,refund_requests.id as refund_requests_id,refund_requests.seller_approval as refund_requests_seller_approval,refund_requests.admin_approval as refund_requests_admin_approval,refund_requests.refund_amount as refund_requests_refund_amount,refund_requests.refund_status as refund_requests_refund_status,refund_requests.refund_delivery_status as refund_requests_refund_delivery_status,refund_requests.tracking_url as refund_requests_tracking_url,refund_requests.reject_reason as refund_requests_reject_reason,refund_requests.defective as refund_requests_defective,refund_requests.reason as refund_requests_reason,refund_requests.admin_seen as refund_requests_admin_seen,refund_requests.refund_cargo_barcode as refund_requests_refund_cargo_barcode,refund_requests.created_at as refund_requests_created_at,refund_requests.updated_at as refund_requests_updated_at,refund_request_conversations.created_at as  '@timestamp' from refund_request_conversations  left join refund_requests on refund_requests.id=refund_request_conversations.refund_request_id"
    use_column_value => true
    tracking_column => "refund_request_conversation_id"
    jdbc_paging_enabled => "true"
    jdbc_page_size => 10000
  }
}
 filter {
 

    mutate  {
          
          rename=>  {
          
            }
    }
}

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

}