zhangyunyun created FLINK-21291:
-----------------------------------
Summary: FlinkKafka Consumer can't dynamic discover the partition
update
Key: FLINK-21291
URL: https://issues.apache.org/jira/browse/FLINK-21291
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.11.2
Reporter: zhangyunyun
When start the job, occurs WARN log like below:
{code:java}
WARN org.apache.kafka.clients.consumer.ConsumerConfig - The configuration
'flink.partition-discovery.interval-millis' was supplied but isn't a known
config.
{code}
And I try to change the kafka partion with command, partition number from 3 to 4
{code:java}
./kafka-topics.sh --alter --zookeeper 10.0.10.21:15311 --topic STRUCTED_LOG
--partitions 4
{code}
it dosen't work.
How can I do with this problem. Thanks a lot
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
