About Kafka output plugin


#1

Hello every one.

I'm using the Kafka output plugin to send data to Spark.

My code is like this :

output {
	stdout {
		codec => rubydebug
	}	

	kafka {
		codec => rubydebug
		topic_id => "toSpark"
		bootstrap_servers => "localhost:9092"
	}
}

I wonder if it has a function that a user can choose and send a few fields not all fileds.


#2

Oh.. I realized

kafka {
		codec => plain {
			format => "%{standard_result}"
		}
		topic_id => "toSpark"
		bootstrap_servers => "localhost:9092"

	}

It works well


(system) #3

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