RE: confirm subscribe to user@flink.apache.org

} } Any help would be appreciated. Thanks and regards,   ANITA KUMARI |  Software Engineer Sr  |  Insight t. 480-366-7025  |  c. 913.272.9568  |  anita.kum...@insight.com  |  insight.com  -Original Message- From: Kumari, Anita Sent: Monday, October 9, 2023 8:47 AM To: us

Re: subscribe

Please send an e-mail to user-subscr...@flink.apache.org to subscribe to the flink user mail list. Best, Hang mark 于2023年3月15日周三 22:07写道： > subscribe >

subscribe

subscribe

Re: I want to subscribe users' questions

ser-zh" 发送时间: 星期五, 2023年 2 月 03日 下午 7:48:55 主题: I want to subscribe users' questions Hi, My name is Guanyuan Chen.I am a big data development engineer, tencent wechat department, china. I have 4 years experience in flink developing, and want to subscribe flink's development news and hel

Re: I want to subscribe users' questions

ser-zh" 发送时间: 星期五, 2023年 2 月 03日 下午 7:48:55 主题: I want to subscribe users' questions Hi, My name is Guanyuan Chen.I am a big data development engineer, tencent wechat department, china. I have 4 years experience in flink developing, and want to subscribe flink's development news and hel

Re: I want to subscribe users' questions

Hi, guanyuan, This document( https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list) will be helpful. welcome~ Best, Hang guanyuan chen 于2023年2月7日周二 21:37写道： > Hi, > My name is Guanyuan Chen.I am a big data development engineer, tencent > wechat department,

Re: I want to subscribe users' questions

Hi, guanyuan, This document( https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list) will be helpful. welcome~ Best, Hang guanyuan chen 于2023年2月7日周二 21:37写道： > Hi, > My name is Guanyuan Chen.I am a big data development engineer, tencent > wechat department,

I want to subscribe users' questions

Hi, My name is Guanyuan Chen.I am a big data development engineer, tencent wechat department, china. I have 4 years experience in flink developing, and want to subscribe flink's development news and help someone developing flink job willingly. Thanks a lot.

Re: confirm subscribe to user@flink.apache.org

istrative requests automatically. Please do not send them to the list address! Instead, send your message to the correct command address: To subscribe to the list, send a message to:   To remove your address from the list, send a message to:   Send mail to the following for info and FAQ for t

Re: subscribe

To subscribe, please send a mail to user-subscr...@flink.apache.org On Fri, Jun 4, 2021 at 4:56 AM Boyang Chen wrote: > >

subscribe

Re: How To subscribe a Kinesis Stream using enhance fanout?

Hi all, Just to give a quick update: there will be contributors from the AWS Kinesis team working on contributing enhanced fan out support to the connector. You can follow the progress here: https://issues.apache.org/jira/browse/FLINK-17688 Cheers, Gordon On Fri, May 15, 2020 at 5:55 PM

Re: How To subscribe a Kinesis Stream using enhance fanout?

Hi, We also recently needed this functionality, unfortunately we were unable to implement it ourselves so changed our plan accordingly. However we very much see the benefit for this feature and would be interested in following the JIRA ticket. Thanks ‐‐‐ Original Message ‐‐‐ On

Re: How To subscribe a Kinesis Stream using enhance fanout?

Hi Xiaolong, You are right, the way the Kinesis connector is implemented / the way the AWS APIs are used, does not allow it to consume Kinesis streams with enhanced fan-out enabled consumers [1]. Could you open a JIRA ticket for this? As far as I can tell, this could be a valuable contribution to

How To subscribe a Kinesis Stream using enhance fanout?

Hello Flink Community! I'm currently coding on a project relying on AWS Kinesis. With the provided connector (flink-connector-kinesis_2.11;1.10.0), I can consume the message. But as the main stream is used among several other teams, I was required to use the enhance fanout of Kinesis.

????: ?????? ??flink-connector-kafka??????????Subscribe????

:14 user-zh; zhisheng2018 ?? ?? ??flink-connector-kafka??Subscribe Hi?? ??kafka??Flink??kafka??rebalance

?????? ??flink-connector-kafka??????????Subscribe????

Hi?? ??kafka??Flink??kafka??rebalance??

Re: 【flink-connector-kafka】是否支持Subscribe模式

可以使用不同的 group.id 消费 i'mpossible <605769...@qq.com> 于2020年4月21日周二 下午6:12写道： > Hi： > Flink支持Subscribe模式吗？用的connector版本是 > flink-connector-kafka-0.11_2.11，0.11x； > 因为业务需要，我想要优雅下线掉TopicB，即不中断事件流；执行结果发现当Flink服务和A服务指定同一个group.id > ，同时消费TopicA时，kafka偏移量提交失败（开启了检查点）； > > > 感谢解答！！！ >

??flink-connector-kafka??????????Subscribe????

Hi?? FlinkSubscribeconnector??flink-connector-kafka-0.11_2.11??0.11x?? ??TopicBFlink??A??group.id??TopicAkafka ??

Re: subscribe

Hi Giriraj, in order to subscribe to Flink's ML you have to send an email to user-subscr...@flink.apache.org. Cheers, Till On Fri, Apr 3, 2020 at 8:30 AM Giriraj Chauhan wrote: > >

subscribe

Re: subscribe messages

Hi, Jianhui! To subscribe, please send an e-mail to user-subscr...@flink.apache.org instead. For more information on mailing list subscriptions, check [1]. [1] https://flink.apache.org/community.html#mailing-lists On Wed, Mar 25, 2020 at 10:07 AM Jianhui <980513...@qq.com> wrote: > >

subscribe messages

subscribe flink

subscribe flink

subscribe flink

subscribe flink

subscribe

subscribe

subscribe

Re: Subscribe Mail list

It is a mistake. Thank you :) On Fri, Mar 22, 2019 at 10:26 AM Pablo Estrada wrote: > Hi Peter, > You'll have to email user-subscr...@flink.apache.org to be able to > subscribe : ) > Best > -P. > > On Fri, Mar 22, 2019 at 10:22 AM Peter Huang > wrote: > >> >>

Re: Subscribe Mail list

Hi Peter, You'll have to email user-subscr...@flink.apache.org to be able to subscribe : ) Best -P. On Fri, Mar 22, 2019 at 10:22 AM Peter Huang wrote: > >

Subscribe Mail list

Re: subscribe

Will do, thanks! On Tue, Feb 19, 2019 at 8:57 AM Fabian Hueske wrote: > Hi Artur, > > In order to subscribe to Flink's user mailing list you need to send a mail > to user-subscr...@flink.apache.org > > Best, Fabian > > Am Mo., 18. Feb. 2019 um 20:34 Uhr schrieb

Re: subscribe

Hi Artur, In order to subscribe to Flink's user mailing list you need to send a mail to user-subscr...@flink.apache.org Best, Fabian Am Mo., 18. Feb. 2019 um 20:34 Uhr schrieb Artur Mrozowski : > art...@gmail.com >

subscribe

art...@gmail.com

Re: Why FlinkKafkaConsumer doesn't subscribe to topics?

ted with Fink’s checkpoints. > If it were to use Kafka’s automatic consumer group assignments (i.e. when > using the subscribe API), the consumer would have no control over when > exactly partition subscriptions are reassigned across subtasks. > If I understood correctly, what you were suggesting

Re: Why FlinkKafkaConsumer doesn't subscribe to topics?

the current offsets of partitions that it is assigned, and that is coordinated with Fink’s checkpoints. If it were to use Kafka’s automatic consumer group assignments (i.e. when using the subscribe API), the consumer would have no control over when exactly partition subscriptions are reassigned across

Re: Why FlinkKafkaConsumer doesn't subscribe to topics?

Hi Renjie, 1. For what I could grasp from Kafka docs, you can subscribe and still use poll() to capture a specific offset. But I just read the starting point of it and didn't go deep into it. 2. Currently, Flink 1.4.2, Kafka 0.10.1 and the FlinkKafkaConsumer010. On Tue, Sep 4, 2018 at 12:47 AM

Re: Why FlinkKafkaConsumer doesn't subscribe to topics?

Hi, Julio: 1. Flink doesn't use subscribe because it needs to control partition assignment itself, which is important for implementing exactly once. 2. Can you share the versions you are using, including kafka, kafka client, flink? We are also use flink kafka consumer and we can monitor

Why FlinkKafkaConsumer doesn't subscribe to topics?

a lot of -Inf, which I already discussed before.) While looking at the problem, we noticed that the FlinkKafkaConsumer never uses `subscribe` to subscribe to the topics and that's why the values are never stored back into Kafka, even when the driver itself does `commitAsync`. Is there any reason

Re: subscribe

To subscribe to this mailing list, please send a mail to user-subscr...@flink.apache.org . On 05.12.2017 08:21, Xin Wang wrote: hello flink -- Thanks, Xin

subscribe

hello flink -- Thanks, Xin

Re: Flink BucketingSink, subscribe on moving of file into final state

You’re welcome. Unfortunately I am not aware about a such use case before Piotrek > On 20 Oct 2017, at 13:47, Rinat wrote: > > Piotrek, thanks for your reply. > > Yes, now I’m looking for the most suitable way to extend BucketingSink > functionality, to handle

Re: Flink BucketingSink, subscribe on moving of file into final state

Piotrek, thanks for your reply. Yes, now I’m looking for the most suitable way to extend BucketingSink functionality, to handle moments of moving the file into final state. I thought, that maybe someone has already implemented such thing or knows any other approaches that will help me to not

Flink BucketingSink, subscribe on moving of file into final state

Hi All ! I’m trying to create a meta-info file, that contains link to file, created by Flink BucketingSink. At first I was trying to implement my own org.apache.flink.streaming.connectors.fs.Writer, that creates a meta-file on close method call. But I understood, that it’s not completely

Re: Subscribe

Hi Stephen, You would have to send a mail to "user-subscr...@flink.apache.org " Best, Aljoscha > On 10. Oct 2017, at 20:08, Stephen Jiang wrote: > >

Subscribe