Hi，张云云
1. flink.partition-discovery.interval-millis
是kafka的一个配置参数，不知道你是不是通过kafkaProp设置的
2. 通过shell查看topic分区是否顺利增加，并且有数据写入。
Best，
Robin
张云云 wrote
> When start the job, occurs WARN log like below:
>
> WARN org.apache.kafka.clients.consumer.ConsumerConfig - The
> configuration 'flink.partition-discovery.interval-millis' was supplied
> but isn't a known config.
>
>
>
>
> And I try to change the kafka partion with command, partition number from
> 3
> to 4
>
> ./kafka-topics.sh --alter --zookeeper 10.0.10.21:15311 --topic
> STRUCTED_LOG --partitions 4
>
> it dosen't work.
>
>
>
> How can I do with this problem. Thanks a lot
--
Sent from: http://apache-flink.147419.n8.nabble.com/
