[jira] [Created] (STORM-2121) StringKeyValueScheme doesn't override getOutputFields()

["Andreas Maier (JIRA)" <ji...@apache.org>]

Andreas Maier created STORM-2121:
------------------------------------

             Summary: StringKeyValueScheme doesn't override getOutputFields()
                 Key: STORM-2121
                 URL: https://issues.apache.org/jira/browse/STORM-2121
             Project: Apache Storm
          Issue Type: Bug
          Components: storm-kafka
            Reporter: Andreas Maier


In org.apache.storm.kafka StringKeyValueScheme extends StringScheme. However it doesn't override the method getOutputFields() from StringScheme 
{code}
public Fields getOutputFields() {
        return new Fields(STRING_SCHEME_KEY);
    }
{code}
And this method returns only one field, instead of two (one for key and one for value), which causes problems. 
It would be better to override the method getOutputFields() in StringKeyValueScheme with e.g. 
{code}
    @Override
    public Fields getOutputFields() {
        return new Fields(FieldNameBasedTupleToKafkaMapper.BOLT_KEY, FieldNameBasedTupleToKafkaMapper.BOLT_MESSAGE);
    }
{code}
The important thing is, that getOutputFields() should return two fields and not one. 



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