[SAMZA-1026] HDFS System Producer should not have Kafka dependency

• Type: Sub-task
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 0.13.0
• Assignee: Prateek Maheshwari
• Reporter: Hai Lu
• Created: 28/Sep/16 16:57
• Updated: 26/Apr/17 23:55
• Resolved: 26/Apr/17 23:55

Description

Currently HDFSSystemFactory has seemly unnecessary dependency on Kafka:

def getProducer(systemName: String, config: Config, registry: MetricsRegistry) =

{ val clientId = KafkaUtil.getClientId("samza-producer", config) val metrics = new HdfsSystemProducerMetrics(systemName, registry) new HdfsSystemProducer(systemName, clientId, config, metrics) }

Should try to get rid of the dependency

Issue Links

• links to: GitHub Pull Request #144