search

RuckusWirelessIL / pentaho-kafka-producer

Apache Kafka producer step plug-in for Pentaho Kettle.
Apache License 2.0
45 stars 33 forks source link

how to use kafka producer #20

Closed vihcle closed 7 years ago

vihcle commented 7 years ago

I now to test the kafka producer plugin. The input is a csv file. In the "Message field name", I set a field in the csv file, when i run the transform, the result is that Input field 'ORDERNUMBER' is not binary.

spektom commented 7 years ago

Can you post the complete exception / error message?

vihcle commented 7 years ago

hello, How to use Table Input and kafka producer?

vihcle commented 7 years ago

kettle_kafka

vihcle commented 7 years ago

This is my error image

spektom commented 7 years ago

@vihcle Kafka producer step only supports Binary or String value types passed as "Message field name" or "Key field name" parameters. Can you verify that BORDER_TYPE is one of these? If not, maybe you can configure it to be either String or Binary?

vihcle commented 7 years ago

OK, Thank You.

vihcle commented 7 years ago

fail_to_send

vihcle commented 7 years ago

Kafka cluster is not in the local, and send message failed.

spektom commented 7 years ago

@vihcle Can you make sure that you are able to send messages to this broker: 192.168.123.218:6667 via Kafka console producer? I suspect the port number 6667 is wrong, usually it's 9092.

spektom commented 7 years ago

Closing due to no response