"Partition. The assignment. The strategy" which has no default value.-CodePudding

Sparkstreaming after analyzing the data, to kafka send data error below

The 2017-05-04 13:03:35, 105 [Executor task launch worker - 0] ERROR [org. Apache. Spark. Executor. Executor] 96 - Exception in task 0.0 in stage 59.0 52 (dar)
Org.apache.kafka.com mon. Config. ConfigException: Missing the required configuration partition. The assignment. "the strategy" which has no default value.
At org.apache.kafka.com, mon. Config. ConfigDef. Parse (ConfigDef. Java: 124)
At org.apache.kafka.com, mon. Config. AbstractConfig. & lt; init> (AbstractConfig. Java: 48)
The at org. Apache. Kafka. Clients. Consumer. ConsumerConfig. & lt; init> (ConsumerConfig. Java: 194)
The at org. Apache. Kafka. Clients. Consumer. KafkaConsumer. & lt; init> (KafkaConsumer. Java: 430)
The at org. Apache. Kafka. Clients. Consumer. KafkaConsumer. & lt; init> (KafkaConsumer. Java: 413)
The at org. Apache. Kafka. Clients. Consumer. KafkaConsumer. & lt; init> (KafkaConsumer. Java: 400)
At com. Unistacks. Tamboo. Kafkaclient. View ConfigHelper. GetConfigConsumer (ConfigHelper. Java: 78)
At com. Unistacks. Tamboo. Kafkaclient. View ConfigHelper. GetConfig (ConfigHelper. Java: 35)
At com. Unistacks. Tamboo. Kafkaclient. View ConfigHelper. The getProperties (ConfigHelper. Java: 94)
At com. Unistacks. Tamboo. Kafkaclient. View ConfigHelper. GetProducerProperties (ConfigHelper. Java: 105)
At com. Unistacks. Tamboo. Kafkaclient. Producer. KafkaProducerFactory. GetProducerCommon (KafkaProducerFactory. Java: 33)
At com. Unistacks. Tamboo. Kafkaclient. Producer. KafkaProducerFactory. GetProducer (KafkaProducerFactory. Java: 17)
At com. Bigdata. Spark. Utils. KafkaClient. & lt; init> (KafkaClient. Java: 30)
At com. Bigdata. Spark. Utils. KafkaFactory $$$getOrCreateProducer anonfun $1. Apply (KafkaFactory. Scala: 24)
At com. Bigdata. Spark. Utils. KafkaFactory $$$getOrCreateProducer anonfun $1. Apply (KafkaFactory. Scala: 22)
At the scala. Collection. The mutable. MapLike $class. GetOrElseUpdate (MapLike. Scala: 189)
At the scala. Collection. Mutable. AbstractMap. GetOrElseUpdate (91). The Map scala:
At com. Bigdata. Spark. Utils. KafkaFactory $. GetOrCreateProducer (KafkaFactory. Scala: 22)
At com. Bigdata. Spark. DirectKafkaWordCount 2 $$$$$main anonfun $anonfun $$1. Apply the apply (DirectKafkaWordCount. Scala: 131)
At com. Bigdata. Spark. DirectKafkaWordCount 2 $$$$$main anonfun $anonfun $$1. Apply the apply (DirectKafkaWordCount. Scala: 130)
At org. Apache. Spark. RDD. RDD $$$foreachPartition anonfun $1 $$anonfun $apply $29. Apply (RDD. Scala: 878)
At org. Apache. Spark. RDD. RDD $$$foreachPartition anonfun $1 $$anonfun $apply $29. Apply (RDD. Scala: 878)
The at org. Apache. Spark. SparkContext $$$runJob anonfun $5. The apply (SparkContext. Scala: 1765)
The at org. Apache. Spark. SparkContext $$$runJob anonfun $5. The apply (SparkContext. Scala: 1765)
The at org. Apache. Spark. The scheduler. ResultTask. RunTask (ResultTask. Scala: 63)
At org. Apache. Spark. The scheduler. Task. Run (70) Task. Scala:
The at org. Apache. Spark. Executor. $TaskRunner executor. Run (executor. Scala: 213)
The at Java. Util. Concurrent. ThreadPoolExecutor. RunWorker (ThreadPoolExecutor. Java: 1145)
The at Java. Util. Concurrent. ThreadPoolExecutor $Worker. The run (ThreadPoolExecutor. Java: 615)
The at Java. Lang. Thread. The run (Thread. Java: 745)
The 2017-05-04 13:03:35, 106 [task - result - getter - 0] WARN [org. Apache. Spark. The scheduler. TaskSetManager] 71 - Lost task in stage 59.0 0.0 (dar 52, localhost) : org.apache.kafka.com mon. Config. ConfigException: Missing the required configuration "partition. The assignment. The strategy" which has no default value.
At org.apache.kafka.com, mon. Config. ConfigDef. Parse (ConfigDef. Java: 124)
At org.apache.kafka.com, mon. Config. AbstractConfig. & lt; init> (AbstractConfig. Java: 48)
The at org. Apache. Kafka. Clients. Consumer. ConsumerConfig. & lt; init> (ConsumerConfig. Java: 194)
The at org. Apache. Kafka. Clients. Consumer. KafkaConsumer. & lt; init> (KafkaConsumer. Java: 430)
The at org. Apache. Kafka. Clients. Consumer. KafkaConsumer. & lt; init> (KafkaConsumer. Java: 413)
The at org. Apache. Kafka. Clients. Consumer. KafkaConsumer. & lt; init> (KafkaConsumer. Java: 400)
At com. Unistacks. Tamboo. Kafkaclient. View ConfigHelper. GetConfigConsumer (ConfigHelper. Java: 78)
At com. Unistacks. Tamboo. Kafkaclient. View ConfigHelper. GetConfig (ConfigHelper. Java: 35)
At com. Unistacks. Tamboo. Kafkaclient. View ConfigHelper. The getProperties (ConfigHelper. Java: 94)
At com. Unistacks. Tamboo. Kafkaclient. View ConfigHelper. GetProducerProperties (ConfigHelper. Java: 105)
At com. Unistacks. Tamboo. Kafkaclient. Producer. KafkaProducerFactory. GetProducerCommon (KafkaProducerFactory. Java: 33)
At com. Unistacks. Tamboo. Kafkaclient. Producer. KafkaProducerFactory. GetProducer (KafkaProducerFactory. Java: 17)
At com. Bigdata. Spark. Utils. KafkaClient. & lt; init> (KafkaClient. Java: 30)
At com. Bigdata. Spark. Utils. KafkaFactory $$$getOrCreateProducer anonfun $1. Apply (KafkaFactory. Scala: 24)
At com. Bigdata. Spark. Utils. KafkaFactory $$$getOrCreateProducer anonfun $1. Apply (KafkaFactory. Scala: 22)
At the scala. Collection. The mutable. MapLike $class. GetOrElseUpdate (MapLike. Scala: 189)
At the scala. Collection. Mutable. AbstractMap. GetOrElseUpdate (91). The Map scala:
nullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnullnull