Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

kafka "partition.assignment.strategy" ERROR

kafka "partition.assignment.strategy" ERROR

New Contributor

Hey,

I have a scala app that use spark and kafka when i try to run it on local machine evrythings work as excepcted but when i try to run it on cluster using Ozzie i get error:

ERROR StreamingContext: Error starting the context, marking it as stopped org.apache.kafka.common.config.ConfigException: Missing required configuration "partition.assignment.strategy" which has no default value

i use kafka 0.10

Don't have an account?
Coming from Hortonworks? Activate your account here