# SOLVED - Logstash-output-kafka JDBC Results

**URL:** <https://discuss.elastic.co/t/solved-logstash-output-kafka-jdbc-results/109829>\
**Category:** Logstash\
**Created:** [November 30, 2017, 7:59pm UTC](https://discuss.elastic.co/t/solved-logstash-output-kafka-jdbc-results/109829 "2017-11-30T19:59:42Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![Wayne\_Taylor](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/wayne_taylor/32/45984_2.png) [@Wayne\_Taylor](https://discuss.elastic.co/u/Wayne_Taylor)\
**Post date:** [November 30, 2017, 7:59pm UTC](https://discuss.elastic.co/t/solved-logstash-output-kafka-jdbc-results/109829/1 "2017-11-30T19:59:43Z")

</div>

Hi All,

I have a logstash config that connects to a JDBC connection and I want to output to a Kafka Cluster. I am able to connect fine , I am also seeing messages expect they look like the below rather than my actual message.

2017-11-30T19:23:54.639Z %{host} %{message}

However, if i configure it to read from a csv file instead of example messages show correctly. See example:  
2017-11-30T19:49:35.827Z MB-C02TF1QUGTFM 4,5  
2017-11-30T19:49:35.827Z MB-C02TF1QUGTFM 3,4  
2017-11-30T19:49:35.826Z MB-C02TF1QUGTFM 2,3  
2017-11-30T19:49:35.826Z MB-C02TF1QUGTFM 1,2  
2017-11-30T19:49:35.828Z MB-C02TF1QUGTFM 7,8  
2017-11-30T19:49:35.828Z MB-C02TF1QUGTFM 5,6

Below is my config for CSV:

```
input {
	file {
		path => "example.csv"
	}
}

filter {
	csv {
		autodetect_column_names => "true"
	}
}

output {

	stdout { codec => rubydebug }

    kafka {
        topic_id => "media"
        bootstrap_servers => "172.20.85.174:9092"
      }
}

```

Below is my JDBC Configuration. Any ideas?

```
input {
	jdbc {
    	jdbc_connection_string => "jdbc:mysql://db:3306/db"
		jdbc_user => "user"
		jdbc_password => "password"
		jdbc_driver_library => "/opt/logstash-5.3.0/bin/mysql-connector-java-5.1.42-bin.jar"
		jdbc_driver_class => "com.mysql.jdbc.Driver"

		statement => "select * from table"
	}
}

filter {
	csv {
		autodetect_column_names => "true"
	}
}

output {

	stdout { codec => rubydebug }

    kafka {
        topic_id => "media"
        bootstrap_servers => "172.20.85.174:9092"
      }
}

```

Thank you!

---

<div class="post-metadata">

**Author:** ![Wayne\_Taylor](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/wayne_taylor/32/45984_2.png) [@Wayne\_Taylor](https://discuss.elastic.co/u/Wayne_Taylor)\
**Post date:** [November 30, 2017, 8:36pm UTC](https://discuss.elastic.co/t/solved-logstash-output-kafka-jdbc-results/109829/2 "2017-11-30T20:36:35Z")

</div>

Solved - answer found on stackoverflow: [https://stackoverflow.com/questions/44680942/logstash-kafka-output](https://stackoverflow.com/questions/44680942/logstash-kafka-output)

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [December 28, 2017, 8:36pm UTC](https://discuss.elastic.co/t/solved-logstash-output-kafka-jdbc-results/109829/3 "2017-12-28T20:36:37Z")

</div>

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