Unable to load CSV data into elastic search

[anilpraneeth (anil praneeth vure)]

Hi Team,
Trying elasticsearch for the first time, bear with my layman questions. I'm trying to load csv formatted data into kafka topic and eventual load into elastic search index. But i'm facing errors loading data from my topic into elasticsearch. Any thoughts on this? appreciate the help.

Cannot create mapping {"kafka-connect":{"type":"text","fields":{"keyword":{"type":"keyword","ignore_above":256}}}} -- {"root_cause":[{"type":"mapper_parsing_exception","reason":"Root mapping definition has unsupported parameters: [type : text] [fields : {keyword={type=keyword, ignore_above=256}}]"}],"type":"mapper_parsing_exception","reason":"Root mapping definition has unsupported parameters: [type : text] [fields : {keyword={type=keyword, ignore_above=256}}]"}

[warkolm (Mark Walkom)]

How is the topic sending data to Elasticsearch?

[anilpraneeth (anil praneeth vure)]

using open source confluent version of kafka and i'm executing below command to load into elasticsearch.

./bin/connect-standalone etc/kafka/connect-standalone.properties etc/kafka-connect-elasticsearch/quickstart-elasticsearch.properties &

[balumurari1]

hope this helps you

Load csv file in logstash

Thanks for reply,hope this works fine, input { file { path => "D:/Balu/ELK-stack/csvfile.csv" start_position => "beginning" sincedb_path => "NUL" } } filter { csv { separator => "," columns => ["open","high","low","close","volume"] } } output { elasticsearch { hosts => "http://localhost:9200" index => "wallet-address-index" } stdout { codec => rubydebug } }

[anilpraneeth (anil praneeth vure)]

Used Logstash and it worked pretty seamlessly, thank you for all the help.