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

Posted to dev@flink.apache.org by "zhangyunyun (Jira)" <ji...@apache.org> on 2020/09/15 09:02:00 UTC

[jira] [Created] (FLINK-19239) FlinkKafkaProducer

zhangyunyun created FLINK-19239:
-----------------------------------

             Summary: FlinkKafkaProducer
                 Key: FLINK-19239
                 URL: https://issues.apache.org/jira/browse/FLINK-19239
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
    Affects Versions: 1.11.0
            Reporter: zhangyunyun


When I use the kafka connector jar: flink-connector-kafka_2.11

My code is:
{code:java}
//代码占位符
new FlinkKafkaProducer<>(
    brokerList,
    topic,
    new SimpleStringSchema()
);
{code}
The target Kafka partition is big then 1, but all the data send to one partition only.

 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)