Re: cannot resolve constructor when invoke FlinkKafkaProducer011 constructor in scala

2018-10-10 Thread 远远
IDEA only show "cannot resolve constructor" error message, without other error message. Dawid Wysakowicz 于2018年10月10日周三 下午5:55写道： > Hi, > > what is the exact error message you are getting? > > Best, > > Dawid > > On 10/10/18 11:51, 远远 wrote: > > invoke FlinkKafkaProducer011 constructor in scala:

Re: cannot resolve constructor when invoke FlinkKafkaProducer011 constructor in scala

2018-10-10 Thread Dawid Wysakowicz
Hi, what is the exact error message you are getting? Best, Dawid On 10/10/18 11:51, 远远 wrote: > invoke FlinkKafkaProducer011 constructor in scala: > val producer = new > FlinkKafkaProducer011[PVEvent.Entity](appConf.getPvEventTopic, new > PvEventSerializeSchema, producerProps, > Optional.of

cannot resolve constructor when invoke FlinkKafkaProducer011 constructor in scala

2018-10-10 Thread 远远
invoke FlinkKafkaProducer011 constructor in scala: val producer = new FlinkKafkaProducer011[PVEvent.Entity](appConf.getPvEventTopic, new PvEventSerializeSchema, producerProps, Optional.of(FlinkRebalancePartitioner[PVEvent.Entity])) and the constructor is : /** * Creates a FlinkKafkaProducer