You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 赵一旦 <hi...@gmail.com> on 2020/11/18 09:47:59 UTC
Re: Re: 回复:回复:回复:flinksql指定kafka多topic
这个问题现在应该还是无解的吧。那个topic-pattern看了下文档也不存在还,1.11不支持对吗?
hailongwang <18...@163.com> 于2020年10月26日周一 下午8:37写道:
> Hi s_hongliang,
> 目前的 Master 分支(1.12) 版本支持一个 source 指定消费多个 topics。
> 相关issue见:https://issues.apache.org/jira/browse/FLINK-18449
>
> 目前你可以拆成多个 Source 消费。
>
>
>
>
> Best,
> Hailong Wang
>
>
>
>
> 在 2020-10-26 13:54:40,"奔跑的小飞袁" <s_...@126.com> 写道:
> >with (
> > 'connector'='kafka',
> >
>
> >'topic'='cloud_behavior;cloud_behavior_other;cloud_behavior_qxb;cloud_behavior_cc;cloud_behavior_cs',
> > 'properties.bootstrap.servers'='',
> > 'properties.group.id'='flink_2_hive_and_imei_ncrypy_test',
> > 'format'='avro',
> > 'scan.startup.mode'='group-offsets'
> >);
> >
> >这是我的配置,但是在执行的时候失败了,我想知道目前支持的flinksql版本是哪个
> >
> >
> >
> >--
> >Sent from: http://apache-flink.147419.n8.nabble.com/
>
Re:Re: Re: 回复:回复:回复:flinksql指定kafka多topic
Posted by hailongwang <18...@163.com>.
是的,或者自己可以 cherry-pick 这个 MR,然后编译把。
在 2020-11-18 16:47:59,"赵一旦" <hi...@gmail.com> 写道:
>这个问题现在应该还是无解的吧。那个topic-pattern看了下文档也不存在还,1.11不支持对吗?
>
>hailongwang <18...@163.com> 于2020年10月26日周一 下午8:37写道:
>
>> Hi s_hongliang,
>> 目前的 Master 分支(1.12) 版本支持一个 source 指定消费多个 topics。
>> 相关issue见:https://issues.apache.org/jira/browse/FLINK-18449
>>
>> 目前你可以拆成多个 Source 消费。
>>
>>
>>
>>
>> Best,
>> Hailong Wang
>>
>>
>>
>>
>> 在 2020-10-26 13:54:40,"奔跑的小飞袁" <s_...@126.com> 写道:
>> >with (
>> > 'connector'='kafka',
>> >
>>
>> >'topic'='cloud_behavior;cloud_behavior_other;cloud_behavior_qxb;cloud_behavior_cc;cloud_behavior_cs',
>> > 'properties.bootstrap.servers'='',
>> > 'properties.group.id'='flink_2_hive_and_imei_ncrypy_test',
>> > 'format'='avro',
>> > 'scan.startup.mode'='group-offsets'
>> >);
>> >
>> >这是我的配置,但是在执行的时候失败了,我想知道目前支持的flinksql版本是哪个
>> >
>> >
>> >
>> >--
>> >Sent from: http://apache-flink.147419.n8.nabble.com/
>>