You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "Stig Rohde Døssing (JIRA)" <ji...@apache.org> on 2017/06/10 10:50:18 UTC

[jira] [Created] (STORM-2548) Simplify KafkaSpoutConfig

Stig Rohde Døssing created STORM-2548:
-----------------------------------------

             Summary: Simplify KafkaSpoutConfig
                 Key: STORM-2548
                 URL: https://issues.apache.org/jira/browse/STORM-2548
             Project: Apache Storm
          Issue Type: Improvement
    Affects Versions: 2.0.0
            Reporter: Stig Rohde Døssing
            Assignee: Stig Rohde Døssing


Some suggestions for simplifying KafkaSpoutConfig off the mailing list:

* We should not duplicate properties that users would normally set in the KafkaConsumer properties map. We should just have a setter (setProp) for setting properties in that map. For instance, setGroupId is just duplicating a setting that the user should be able to set directly in the consumer properties.

* We should get rid of the key/value deserializer setters. Setting the deserializers as classes is something the user can just as well do by using setProp. The SerializableDeserializer class should be removed. It is only offering extra type safety in the case where the user is defining their own deserializer type, and has the opportunity to subclass SerializableDeserializer. The setters don't work with the built in Kafka deserializers.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)