Flink需要导入kafka-clients来支持对kafka的生产和消费。kafka-clients0.11提供的api仅在kafka0.11、kafka0.10版本可用,如果要对kafka0.8、kafka0.9进行生产和消费,则需要使用版本相匹配的kafka-clients的jar包。但如果直接使用这些jar包会导致jar包冲突,因为里面的类都是在相同包名下的。Flink需要导入kafka-clients来支持对kafka的生产和消费。kafka-clie
Flink需要导入kafka-clients来支持对kafka的生产和消费。kafka-clients0.11提供的api仅在kafka0.11、kafka0.10版本可用,如果要对kafka0.8、kafka0.9进行生产和消费,则需要使用版本相匹配的kafka-clients的jar包。但如果直接使用这些jar包会导致jar包冲突,因为里面的类都是在相同包名下的。Flink需要导入kafka-clients来支持对kafka的生产和消费。kafka-clie