[
https://issues.apache.org/jira/browse/KAFKA-2041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-2041:
---------------------------
Status: In Progress (was: Patch Available)
[~benoyantony], thanks for the patch. We will use
org.apache.kafka.log4jappender.KafkaLog4jAppender (which uses the new java
producer) in the future and phase out the scala KafkaLog4jAppender. Could you
port your patch to the java one?
> 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.patch, kafka-2041-001.patch,
> kafka-2041-002.patch, kafka-2041-003.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)
