You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "zhangyunyun (Jira)" <ji...@apache.org> on 2021/02/05 07:35:00 UTC

[jira] [Created] (FLINK-21291) FlinkKafka Consumer can't dynamic discover the partition update

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)