lib
----
??:"JingsongLee"https://ci.apache.org/projects/flink/flink-docs-master/ops/cli.html#usage
--
From:Others <41486...@qq.com
Send
lib
----
??:"AS"https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/connect.html#dependencies
jarflink??lib??() ??.
??.
??2020??01??15??
Hi:
??, kafka??factory.
??
https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/connect.html#dependencies
jarflink??lib??() ??.
??.
??2020??01??15?? 14:59??Others<41486...@qq.com>
flink ??1.9.1
??
2020-01-15 11:57:44,255 ERROR
org.apache.flink.runtime.webmonitor.handlers.JarRunHandler- Unhandled
exception.
org.apache.flink.client.program.ProgramInvocationException: The main method
caused an error:
Hi All,
我们写kafka
comsumer通常都不需要去管消费哪个partition，comsumer会根据partition.assignment.strategy设置的分配策略自动协商分配每个线程消费哪个或者哪些分区
但在FlinkKafkaConsumer中调用的KafkaConsumerThread这个消费线程代码中有如下代码
try {
if (hasAssignedPartitions) {
newPartitions = unassignedPartitionsQueue.pollBatch();
}
else {
