update kafka.input.topic ---> kafka.topic

dibbhatt / kafka-spark-consumer

High Performance Kafka Connector for Spark Streaming.Supports Multi Topic Fetch, Kafka Security. Reliable offset management in Zookeeper. No Data-loss. No dependency on HDFS and WAL. In-built PID rate controller. Support Message Handler . Offset Lag checker.

Apache License 2.0

635 stars 318 forks source link

update kafka.input.topic ---> kafka.topic #48

Closed ghost closed 7 years ago

ghost commented 7 years ago

@dibbhatt A small bug, writing log topic is null. It is kafka.topic instead of kafka.input.topic.

dibbhatt commented 7 years ago

thanks @Jiwei0 . Yes I see this is a bug in Logging . Is this causing any issue while consuming from Kafka. Then I may need another release.