zhiqiangzhao created FLUME-3074:
-----------------------------------
Summary: format error happened on windows when kafka sink is used
Key: FLUME-3074
URL: https://issues.apache.org/jira/browse/FLUME-3074
Project: Flume
Issue Type: Bug
Components: Sinks+Sources
Affects Versions: 1.7.0
Environment: windows 10
Reporter: zhiqiangzhao
When I use kafka sink to push logs from windows path to kafka server， I meet
the format error as follows
I think it is because windows path was parsed in linux style。
17 三月 2017 11:54:29,476 ERROR [SinkRunner-PollingRunner-DefaultSinkProcessor]
(org.apache.flume.SinkRunner$PollingRunner.run:158) - Unable to deliver event.
Exception follows.
org.apache.flume.EventDeliveryException: Failed to publish events
at org.apache.flume.sink.kafka.KafkaSink.process(KafkaSink.java:252)
at
org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:67)
at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:145)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.flume.EventDeliveryException: Non integer partition id
specified
at org.apache.flume.sink.kafka.KafkaSink.process(KafkaSink.java:214)
... 3 more
Caused by: java.lang.NumberFormatException: For input string:
"C:\Users\smart\Desktop\source\23.txt"
at
java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
at java.lang.Integer.parseInt(Integer.java:580)
at java.lang.Integer.parseInt(Integer.java:615)
at org.apache.flume.sink.kafka.KafkaSink.process(KafkaSink.java:202)
... 3 more
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
