[jira] [Updated] (FLUME-2470) Kafka Sink and Source must use camel case for all configs.

["Gwen Shapira (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLUME-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gwen Shapira updated FLUME-2470:
--------------------------------
    Attachment: FLUME-2470.0.patch

Patch standardizing the parameters.

Mandatory parameters for Kafka source/sink are now camelCase.
Any Kafka parameter can still be passed along using the "kafka."+kafka.parameter.name convention.

I modified the documentation to match, cleaned up the configuration code a bit to support the new logic and added a test to validate.

> Kafka Sink and Source must use camel case for all configs.
> ----------------------------------------------------------
>
>                 Key: FLUME-2470
>                 URL: https://issues.apache.org/jira/browse/FLUME-2470
>             Project: Flume
>          Issue Type: Bug
>            Reporter: Hari Shreedharan
>            Assignee: Gwen Shapira
>         Attachments: FLUME-2470.0.patch
>
>
> Some configs are of the form kafka.* while others are camel cased. This is for ease of implementation as these get passed to Kafka, but this make config params not uniform. We must change this so all configs are camel-cased. We should translate these camel-cased params to the kafka properties to configure the kafka API.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)