[ https://issues.apache.org/jira/browse/KAFKA-2041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14393424#comment-14393424 ]
Tom DeVoe commented on KAFKA-2041: ---------------------------------- One small bug in the most recent patch you uploaded, you changed the Keyer trait function to {{getKey}}, but did not update KafkaLog4jAppender, which still uses the old {{key}} function. Once that was updated, the patch worked great. > Add ability to specify a KeyClass for KafkaLog4jAppender > -------------------------------------------------------- > > Key: KAFKA-2041 > URL: https://issues.apache.org/jira/browse/KAFKA-2041 > Project: Kafka > Issue Type: Improvement > Components: producer > Reporter: Benoy Antony > Assignee: Jun Rao > Attachments: kafka-2041-001.patch, kafka-2041-002.patch > > > KafkaLog4jAppender is the Log4j Appender to publish messages to Kafka. > Since there is no key or explicit partition number, the messages are sent to > random partitions. > In some cases, it is possible to derive a key from the message itself. > So it may be beneficial to enable KafkaLog4jAppender to accept KeyClass which > will provide a key for a given message. -- This message was sent by Atlassian JIRA (v6.3.4#6332)