Output to Kafka

Elastic Stack Logstash
1

i have a logstash conf file that looks like this:

input {

      jdbc {

            jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
            jdbc_connection_string => "jdbc:oracle:thin:@//the-s2.db.oracle.yn:1521/DPP2.mind.com"
            jdbc_user => "STG_TEST"
            jdbc_password => "cddcdcd"
            parameters => {"orderid" => 1212332365}
            statement => "select PO_SEARCH_IL_ID,ORDER_DATE,REF_1,SHIPPING_WINDOW_START,SHIPPING_WINDOW_END FROM ods.po_search_il where PO_SEARCH_IL_ID =:orderid "
            schedule => "* * * * *"
            clean_run => true


    }

}

output {
        kafka {
        bootstrap_servers => "mykafkaservername.kn:9092"
        topic_id => ["test3"]
                }
        }

the Script run the topic test3 is created into the kafka server but no data in there.

snapshot of the kafka UI

Does somebody could help on that error ?

2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.