[STORM-2865] KafkaSpout constructor with KafkaConsumerFactory shoud be public

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Not A Problem
• Affects Version/s: 2.0.0, 1.x
• Component/s: storm-kafka-client
• Environment: kafka version：0.11 ; storm-kafka-client version: 1.1.*
• Assignee: Unassigned
• Reporter: YulongZ
• Created: 22/Dec/17 09:30
• Updated: 27/Apr/18 19:30
• Resolved: 27/Apr/18 19:30

Description

When we use custom implement of interface "Deserializer"，KafkaSpout constructor can only use class "KafkaConsumerFactoryDefault"，the method “configure” of Interface “Deserializer” will not be called。

We need change the "KafkaSpout" constructor with "KafkaConsumerFactory" to be public, so we can create custom custom implement of interface "KafkaConsumerFactory".