[
https://issues.apache.org/jira/browse/KAFKA-130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13119023#comment-13119023
]
Jay Kreps commented on KAFKA-130:
---------------------------------
Hey Jun, the idea of the properties option is this: we want to give a way for
the user to plug in code for parsing the input file, and that code may require
some options of its own. For example you might need to give the charset of the
input file or some other info. To make this possible there needs to be a way to
pass config through this code to the user's plug-in message reader. Obviously
for our usage, the thing I had in mind was being able to pass in an avro schema
or url to get one. This is all fairly advanced functionality, so the user
doesn't need to mess with it unless they want to read in messages a particular
way.
LineMessageReader is a default implementation of this interface that just turns
one line into an input to the producer as a string, used in combination with
the StringEncoder it does the normal logging thing of sending one line as a
message.
Hopefully that makes sense...
> Provide a default producer for receiving messages from STDIN
> ------------------------------------------------------------
>
> Key: KAFKA-130
> URL: https://issues.apache.org/jira/browse/KAFKA-130
> Project: Kafka
> Issue Type: New Feature
> Affects Versions: 0.6
> Reporter: Felix GV
> Assignee: Jay Kreps
> Priority: Minor
> Attachments: kafka-console-producer.patch
>
>
> It would be useful to provide a default producer we can fire up that reads
> from STDIN and sends one message per line to the broker.
> The most obvious use case for this is to pipe a tail -f command into it, to
> tail log files as they're generated. Making it depend on STDIN seems more
> flexible than a producer that just tails files though.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
