Re: [ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Austin Bennett
Congrats! On Mon, Feb 24, 2020, 11:22 PM Alex Van Boxel wrote: > Congrats! > > _/ > _/ Alex Van Boxel > > > On Mon, Feb 24, 2020 at 8:13 PM Kyle Weaver wrote: > >> Thanks Jincheng for all your work on Beam and Flink integration. >> >> On Mon, Feb 24, 2020 at 11:02 AM Yichi Zhang wrote: >>

Re: [VOTE] Upgrade gradle to 6.2

2020-02-24 Thread Jean-Baptiste Onofré
Hi AlexI also have couple of contacts at Gradle. Let me know if needed. Regards JBLe mar. 25 f?vr. 2020 ? 08:20, Alex Van Boxel a ?crit :OK, great. I know someone that works at gradle, so I can ping them when I have some problems.Any other know pitfalls I can expect, let me know :-) _/_/ Alex Van

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Austin Bennett
Hooray! On Mon, Feb 24, 2020, 11:21 PM Alex Van Boxel wrote: > Congrats! > > _/ > _/ Alex Van Boxel > > > On Tue, Feb 25, 2020 at 6:21 AM Thomas Weise wrote: > >> Congratulations! >> >> >> On Mon, Feb 24, 2020, 3:38 PM Ankur Goenka wrote: >> >>> Congratulations Chad! >>> >>> On Mon, Feb 24,

Re: [ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Alex Van Boxel
Congrats! _/ _/ Alex Van Boxel On Mon, Feb 24, 2020 at 8:13 PM Kyle Weaver wrote: > Thanks Jincheng for all your work on Beam and Flink integration. > > On Mon, Feb 24, 2020 at 11:02 AM Yichi Zhang wrote: > >> Congrats, Jincheng! >> >> On Mon, Feb 24, 2020 at 9:45 AM Ahmet Altay wrote: >>

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Alex Van Boxel
Congrats! _/ _/ Alex Van Boxel On Tue, Feb 25, 2020 at 6:21 AM Thomas Weise wrote: > Congratulations! > > > On Mon, Feb 24, 2020, 3:38 PM Ankur Goenka wrote: > >> Congratulations Chad! >> >> On Mon, Feb 24, 2020 at 3:34 PM Ahmet Altay wrote: >> >>> Congratulations! >>> >>> On Mon, Feb 24,

Re: [VOTE] Upgrade gradle to 6.2

2020-02-24 Thread Alex Van Boxel
OK, great. I know someone that works at gradle, so I can ping them when I have some problems. Any other know pitfalls I can expect, let me know :-) _/ _/ Alex Van Boxel On Tue, Feb 25, 2020 at 7:20 AM Jean-Baptiste Onofré wrote: > +1 > > It makes sense. > > Thanks. > Regards > JB > > Le

Re: [VOTE] Upgrade gradle to 6.2

2020-02-24 Thread Jean-Baptiste Onofré
+1It makes sense. Thanks. Regards JBLe lun. 24 f?vr. 2020 ? 22:37, Alex Van Boxel a ?crit :Anyone objections that I upgrade gradle to 6.2. If ok this will be done over several commits where I will:Upgrade pluginsUpgrade gradle to 6.2See where we can use some of the new features _/_/ Alex Van

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Thomas Weise
Congratulations! On Mon, Feb 24, 2020, 3:38 PM Ankur Goenka wrote: > Congratulations Chad! > > On Mon, Feb 24, 2020 at 3:34 PM Ahmet Altay wrote: > >> Congratulations! >> >> On Mon, Feb 24, 2020 at 3:25 PM Sam Bourne wrote: >> >>> Nice one Chad. Your typing efforts are very welcomed. >>> >>>

Re: Please comment on draft comms strategy by Oct 16

2020-02-24 Thread María Cruz
Hi Matthias, thank you for the detailed feedback on the comms strategy. I can definitely help with the Youtube channel revamp and social media copy to promote that content. I will connect off-list with you about this. All: given that we are moving forward with this strategy, I created a pull

Re: [VOTE] Upgrade gradle to 6.2

2020-02-24 Thread Luke Cwik
+1 Can you try testing removing -Ppublishing and no parallel build requirement when doing the release? (some of the Gradle release related plugins had issues when running in parallel which manifested as build errors when doing the release). On Mon, Feb 24, 2020 at 5:43 PM Kenneth Knowles wrote:

Re: [VOTE] Upgrade gradle to 6.2

2020-02-24 Thread Kenneth Knowles
+1 On Mon, Feb 24, 2020 at 5:42 PM Kenneth Knowles wrote: > If I recall correctly, upgrading gradle would unblock getting some better > static analysis plugins. That would be stellar, since we lost a lot of our > analysis when we switched from findbugs to spotbugs (it seems to just not > care

Re: [VOTE] Upgrade gradle to 6.2

2020-02-24 Thread Kenneth Knowles
If I recall correctly, upgrading gradle would unblock getting some better static analysis plugins. That would be stellar, since we lost a lot of our analysis when we switched from findbugs to spotbugs (it seems to just not care as much about some errors, which have since flourished) Kenn On Mon,

Re: [PROPOSAL] Vendored bytebuddy dependency release

2020-02-24 Thread Kenneth Knowles
+1 thanks! On Mon, Feb 24, 2020 at 1:13 PM Pablo Estrada wrote: > +1 > > On Sun, Feb 23, 2020 at 8:31 PM Luke Cwik wrote: > >> +1 >> >> On Sun, Feb 23, 2020 at 7:20 PM jincheng sun >> wrote: >> >>> +1 >>> >>> Best, >>> Jincheng >>> >>> >>> Kai Jiang 于2020年2月23日周日 上午2:26写道: >>> +1

Review Request

2020-02-24 Thread Wenbing Bai
Hi there, Can I get a review on this PR https://github.com/apache/beam/pull/10901? -- Wenbing Bai Senior Software Engineer, MLP Cruise Pronouns: She/Her -- *Confidentiality Note:* We care about protecting our proprietary information, confidential material, and trade secrets. This

Re: Contributor permission for Beam Jira tickets

2020-02-24 Thread Yu Watanabe
Thank you . Sorry for the late reply . On Sun, Feb 16, 2020, 18:25 Ismaël Mejía wrote: > done > > On Sun, Feb 16, 2020 at 9:02 AM Yu Watanabe wrote: > >> Hi, >> >> This is Yu Watanabe from Creationline. >> I would like to contribute issues related to elasticsearch and kafka. >> Can someone add

Re: Docker images are migrated to Apache org.

2020-02-24 Thread Hannah Jiang
Thanks everyone for reporting issues and potential problems etc. Please feel free to let me know if you have any questions or see additional issues! On Mon, Feb 24, 2020 at 4:17 PM Pablo Estrada wrote: > Thanks Hannah! This is great : ) > -P. > > On Mon, Feb 24, 2020 at 12:47 PM Robert Burke

Re: Request to be added as contributor

2020-02-24 Thread Emiliano Capoccia
Thanks Ahmet, best Emiliano On 2020/02/24 23:57:03, Ahmet Altay wrote: > Done. Added you as a contributor. > > On Mon, Feb 24, 2020 at 2:54 PM Emiliano Capoccia < > emiliano.capoc...@gmail.com> wrote: > > > Hi Luke, > > > > that is "ecapoccia" > > > > Thanks, I look forward to hearing from

Re: Docker images are migrated to Apache org.

2020-02-24 Thread Pablo Estrada
Thanks Hannah! This is great : ) -P. On Mon, Feb 24, 2020 at 12:47 PM Robert Burke wrote: > It was only merged in an hour ago. That explains why I still saw it as > broken before lunch. Thanks again! > > On Mon, Feb 24, 2020, 12:42 PM Robert Burke wrote: > >> NVM. I had stale pages for some

Re: Request to be added as contributor

2020-02-24 Thread Ahmet Altay
Done. Added you as a contributor. On Mon, Feb 24, 2020 at 2:54 PM Emiliano Capoccia < emiliano.capoc...@gmail.com> wrote: > Hi Luke, > > that is "ecapoccia" > > Thanks, I look forward to hearing from you > > Emiliano > > On 2020/02/24 17:03:53, Luke Cwik wrote: > > Please provide your user id

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Ankur Goenka
Congratulations Chad! On Mon, Feb 24, 2020 at 3:34 PM Ahmet Altay wrote: > Congratulations! > > On Mon, Feb 24, 2020 at 3:25 PM Sam Bourne wrote: > >> Nice one Chad. Your typing efforts are very welcomed. >> >> On Tue, Feb 25, 2020 at 10:16 AM Yichi Zhang wrote: >> >>> Congratulations, Chad!

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Ahmet Altay
Congratulations! On Mon, Feb 24, 2020 at 3:25 PM Sam Bourne wrote: > Nice one Chad. Your typing efforts are very welcomed. > > On Tue, Feb 25, 2020 at 10:16 AM Yichi Zhang wrote: > >> Congratulations, Chad! >> >> On Mon, Feb 24, 2020 at 3:10 PM Robert Bradshaw >> wrote: >> >>> Well deserved,

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Sam Bourne
Nice one Chad. Your typing efforts are very welcomed. On Tue, Feb 25, 2020 at 10:16 AM Yichi Zhang wrote: > Congratulations, Chad! > > On Mon, Feb 24, 2020 at 3:10 PM Robert Bradshaw > wrote: > >> Well deserved, Chad. Congratulations! >> >> On Mon, Feb 24, 2020 at 2:43 PM Reza Rokni wrote: >>

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Yichi Zhang
Congratulations, Chad! On Mon, Feb 24, 2020 at 3:10 PM Robert Bradshaw wrote: > Well deserved, Chad. Congratulations! > > On Mon, Feb 24, 2020 at 2:43 PM Reza Rokni wrote: > > > > Congratulations! :-) > > > > On Tue, Feb 25, 2020 at 6:41 AM Chad Dombrova wrote: > >> > >> Thanks, folks! I'm

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Robert Bradshaw
Well deserved, Chad. Congratulations! On Mon, Feb 24, 2020 at 2:43 PM Reza Rokni wrote: > > Congratulations! :-) > > On Tue, Feb 25, 2020 at 6:41 AM Chad Dombrova wrote: >> >> Thanks, folks! I'm very excited to "retest this" :) >> >> Especially big thanks to Robert and Udi for all their hard

Re: Request to be added as contributor

2020-02-24 Thread Emiliano Capoccia
Hi Luke, sure, that is: ecapoccia Thanks, I look forward to hearing from you On 2020/02/24 17:03:53, Luke Cwik wrote: > Please provide your user id associated with your JIRA account. > > On Mon, Feb 24, 2020 at 8:38 AM Emiliano Capoccia > wrote: > > > Hi, > > > > This is Emiliano from JP

Re: Request to be added as contributor

2020-02-24 Thread Emiliano Capoccia
Hi Luke, that is "ecapoccia" Thanks, I look forward to hearing from you Emiliano On 2020/02/24 17:03:53, Luke Cwik wrote: > Please provide your user id associated with your JIRA account. > > On Mon, Feb 24, 2020 at 8:38 AM Emiliano Capoccia > wrote: > > > Hi, > > > > This is Emiliano from

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Reza Rokni
Congratulations! :-) On Tue, Feb 25, 2020 at 6:41 AM Chad Dombrova wrote: > Thanks, folks! I'm very excited to "retest this" :) > > Especially big thanks to Robert and Udi for all their hard work reviewing > my PRs. > > -chad > > > On Mon, Feb 24, 2020 at 1:44 PM Brian Hulette wrote: > >>

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Chad Dombrova
Thanks, folks! I'm very excited to "retest this" :) Especially big thanks to Robert and Udi for all their hard work reviewing my PRs. -chad On Mon, Feb 24, 2020 at 1:44 PM Brian Hulette wrote: > Congratulations Chad! Thanks for all your contributions :) > > On Mon, Feb 24, 2020 at 1:43 PM

Re: [VOTE][BIP-1] Beam Schema Options

2020-02-24 Thread Kenneth Knowles
+1 (binding) Added a link to the wiki proposal for SQL/MED (Management of External Data) which treats some of the same ideas. Kenn On Fri, Feb 21, 2020 at 3:02 PM Brian Hulette wrote: > +1 (non-binding) thanks for all your work on this Alex :) > > On Fri, Feb 21, 2020 at 6:50 AM Alex Van

Fwd: [ANN] Last few days remaining to submit Outreachy intern project proposals for upcoming round

2020-02-24 Thread Kenneth Knowles
Hi all, I don't believe this was announced directly on Beam dev. Sorry for that. The deadline for project proposals is 2020-Feb-25 16:00Z. That is less than 24 hours from now. If you have something in mind, please do submit! Kenn -- Forwarded message - From: Matt Sicker Date:

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Brian Hulette
Congratulations Chad! Thanks for all your contributions :) On Mon, Feb 24, 2020 at 1:43 PM Kyle Weaver wrote: > Well-deserved, thanks for your dedication to the project Chad. :) > > On Mon, Feb 24, 2020 at 1:34 PM Udi Meiri wrote: > >> Congrats and welcome, Chad! >> >> On Mon, Feb 24, 2020 at

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Kyle Weaver
Well-deserved, thanks for your dedication to the project Chad. :) On Mon, Feb 24, 2020 at 1:34 PM Udi Meiri wrote: > Congrats and welcome, Chad! > > On Mon, Feb 24, 2020 at 1:21 PM Pablo Estrada wrote: > >> Hi everyone, >> >> Please join me and the rest of the Beam PMC in welcoming a new

[VOTE] Upgrade gradle to 6.2

2020-02-24 Thread Alex Van Boxel
Anyone objections that I upgrade gradle to 6.2. If ok this will be done over several commits where I will: - Upgrade plugins - Upgrade gradle to 6.2 - See where we can use some of the new features _/ _/ Alex Van Boxel

Re: [ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Udi Meiri
Congrats and welcome, Chad! On Mon, Feb 24, 2020 at 1:21 PM Pablo Estrada wrote: > Hi everyone, > > Please join me and the rest of the Beam PMC in welcoming a new committer: > Chad Dombrova > > Chad has contributed to the project in multiple ways, including > improvements to the testing

[ANNOUNCE] New committer: Chad Dombrova

2020-02-24 Thread Pablo Estrada
Hi everyone, Please join me and the rest of the Beam PMC in welcoming a new committer: Chad Dombrova Chad has contributed to the project in multiple ways, including improvements to the testing infrastructure, and adding type annotations throughout the Python SDK, as well as working closely with

Re: [PROPOSAL] Vendored bytebuddy dependency release

2020-02-24 Thread Pablo Estrada
+1 On Sun, Feb 23, 2020 at 8:31 PM Luke Cwik wrote: > +1 > > On Sun, Feb 23, 2020 at 7:20 PM jincheng sun > wrote: > >> +1 >> >> Best, >> Jincheng >> >> >> Kai Jiang 于2020年2月23日周日 上午2:26写道: >> >>> +1 >>> >>> On Sat, Feb 22, 2020 at 09:50 Alex Van Boxel wrote: >>> +1 _/

Re: Custom 2.20 failing on Dataflow: what am I doing wrong?

2020-02-24 Thread Luke Cwik
I look at the gradle task definition to see what additional flags are being passed whenever trying to rerun/repro an issue. Many of our integration tests require additional flags/experiments which are unique on a runner per runner basis. On Wed, Feb 19, 2020 at 9:15 AM Alex Van Boxel wrote: >

Re: Docker images are migrated to Apache org.

2020-02-24 Thread Robert Burke
It was only merged in an hour ago. That explains why I still saw it as broken before lunch. Thanks again! On Mon, Feb 24, 2020, 12:42 PM Robert Burke wrote: > NVM. I had stale pages for some reason. Hannah fixed them already. :D > > On Mon, Feb 24, 2020, 12:39 PM Robert Burke wrote: > >> Looks

Re: Docker images are migrated to Apache org.

2020-02-24 Thread Robert Burke
NVM. I had stale pages for some reason. Hannah fixed them already. :D On Mon, Feb 24, 2020, 12:39 PM Robert Burke wrote: > Looks like the change broke the go post commits. I've filed BEAM-9374 for > it. I think I know how to fix it though. > > On Mon, Feb 24, 2020, 12:18 PM Kyle Weaver wrote:

Re: Docker images are migrated to Apache org.

2020-02-24 Thread Kyle Weaver
Is it still failing after https://github.com/apache/beam/pull/10936? On Mon, Feb 24, 2020 at 12:39 PM Robert Burke wrote: > Looks like the change broke the go post commits. I've filed BEAM-9374 for > it. I think I know how to fix it though. > > On Mon, Feb 24, 2020, 12:18 PM Kyle Weaver wrote:

Re: Docker images are migrated to Apache org.

2020-02-24 Thread Robert Burke
Looks like the change broke the go post commits. I've filed BEAM-9374 for it. I think I know how to fix it though. On Mon, Feb 24, 2020, 12:18 PM Kyle Weaver wrote: > I wonder if searching for "apache beam" (instead of "apache/beam") will > ever work on Docker hub once the new images start

Re: Docker images are migrated to Apache org.

2020-02-24 Thread Kyle Weaver
I wonder if searching for "apache beam" (instead of "apache/beam") will ever work on Docker hub once the new images start getting more downloads. Currently no relevant results are included. Unfortunately this might not be something we can control, as it seems Docker hub's search is not as

Re: [ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Kyle Weaver
Thanks Jincheng for all your work on Beam and Flink integration. On Mon, Feb 24, 2020 at 11:02 AM Yichi Zhang wrote: > Congrats, Jincheng! > > On Mon, Feb 24, 2020 at 9:45 AM Ahmet Altay wrote: > >> Congratulations! >> >> On Mon, Feb 24, 2020 at 6:48 AM Thomas Weise wrote: >> >>>

Re: [ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Yichi Zhang
Congrats, Jincheng! On Mon, Feb 24, 2020 at 9:45 AM Ahmet Altay wrote: > Congratulations! > > On Mon, Feb 24, 2020 at 6:48 AM Thomas Weise wrote: > >> Congratulations! >> >> >> On Mon, Feb 24, 2020 at 6:45 AM Ismaël Mejía wrote: >> >>> Congrats Jincheng! >>> >>> On Mon, Feb 24, 2020 at 1:39

Re: [ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Ahmet Altay
Congratulations! On Mon, Feb 24, 2020 at 6:48 AM Thomas Weise wrote: > Congratulations! > > > On Mon, Feb 24, 2020 at 6:45 AM Ismaël Mejía wrote: > >> Congrats Jincheng! >> >> On Mon, Feb 24, 2020 at 1:39 PM Gleb Kanterov wrote: >> >>> Congratulations! >>> >>> On Mon, Feb 24, 2020 at 1:18 PM

Re: KafkaIO to read from regex topic

2020-02-24 Thread Luke Cwik
I have been working on getting unbounded SDFs working within Beam over portability so if you are interested in writing an SDF KafkaIO implementation, I would be interested. On Mon, Feb 24, 2020 at 7:34 AM Alexey Romanenko wrote: > Hi Maulik, > > For the moment, KafkaIO doesn’t support reading

Re: Request to be added as contributor

2020-02-24 Thread Luke Cwik
Please provide your user id associated with your JIRA account. On Mon, Feb 24, 2020 at 8:38 AM Emiliano Capoccia wrote: > Hi, > > This is Emiliano from JP Morgan Chase. I develop applications in Beam and > run them on a Spark cluster on Kubernetes. Can someone add me as a > contributor for

Request to be added as contributor

2020-02-24 Thread Emiliano Capoccia
Hi, This is Emiliano from JP Morgan Chase. I develop applications in Beam and run them on a Spark cluster on Kubernetes. Can someone add me as a contributor for Beam's Jira issue tracker? I would like to create/assign tickets for my work. Thanks, Emiliano

Re: KafkaIO to read from regex topic

2020-02-24 Thread Alexey Romanenko
Hi Maulik, For the moment, KafkaIO doesn’t support reading from dynamic topics (add/remove topics/partitions) without pipeline restart. In a few words, KafkaIO uses unbounded source API which requires fixed number of splits and it doesn’t deal well with watermarks for empty splits. One of the

Re: [ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Thomas Weise
Congratulations! On Mon, Feb 24, 2020 at 6:45 AM Ismaël Mejía wrote: > Congrats Jincheng! > > On Mon, Feb 24, 2020 at 1:39 PM Gleb Kanterov wrote: > >> Congratulations! >> >> On Mon, Feb 24, 2020 at 1:18 PM Hequn Cheng wrote: >> >>> Congratulations Jincheng, well deserved! >>> >>> Best, >>>

Re: [ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Ismaël Mejía
Congrats Jincheng! On Mon, Feb 24, 2020 at 1:39 PM Gleb Kanterov wrote: > Congratulations! > > On Mon, Feb 24, 2020 at 1:18 PM Hequn Cheng wrote: > >> Congratulations Jincheng, well deserved! >> >> Best, >> Hequn >> >> On Mon, Feb 24, 2020 at 7:21 PM Reza Rokni wrote: >> >>> Congrats! >>> >>>

Re: [ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Gleb Kanterov
Congratulations! On Mon, Feb 24, 2020 at 1:18 PM Hequn Cheng wrote: > Congratulations Jincheng, well deserved! > > Best, > Hequn > > On Mon, Feb 24, 2020 at 7:21 PM Reza Rokni wrote: > >> Congrats! >> >> On Mon, Feb 24, 2020 at 7:15 PM Jan Lukavský wrote: >> >>> Congrats Jincheng! >>> >>>

Beam Dependency Check Report (2020-02-24)

2020-02-24 Thread Apache Jenkins Server
High Priority Dependency Updates Of Beam Python SDK: Dependency Name Current Version Latest Version Release Date Of the Current Used Version Release Date Of The Latest Release JIRA Issue cachetools 3.1.1 4.0.0 2019-12-23

Re: [ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Hequn Cheng
Congratulations Jincheng, well deserved! Best, Hequn On Mon, Feb 24, 2020 at 7:21 PM Reza Rokni wrote: > Congrats! > > On Mon, Feb 24, 2020 at 7:15 PM Jan Lukavský wrote: > >> Congrats Jincheng! >> >> Jan >> >> On 2/24/20 11:55 AM, Maximilian Michels wrote: >> > Hi everyone, >> > >> >

Re: [ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Reza Rokni
Congrats! On Mon, Feb 24, 2020 at 7:15 PM Jan Lukavský wrote: > Congrats Jincheng! > > Jan > > On 2/24/20 11:55 AM, Maximilian Michels wrote: > > Hi everyone, > > > > Please join me and the rest of the Beam PMC in welcoming a new > > committer: Jincheng Sun > > > > Jincheng has worked on

Re: [ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Jan Lukavský
Congrats Jincheng!  Jan On 2/24/20 11:55 AM, Maximilian Michels wrote: Hi everyone, Please join me and the rest of the Beam PMC in welcoming a new committer: Jincheng Sun Jincheng has worked on generalizing parts of Beam for Flink's Python API. He has also picked up other issues, like

[ANNOUNCE] New committer: Jincheng Sun

2020-02-24 Thread Maximilian Michels
Hi everyone, Please join me and the rest of the Beam PMC in welcoming a new committer: Jincheng Sun Jincheng has worked on generalizing parts of Beam for Flink's Python API. He has also picked up other issues, like fixing documentation, implementing missing features, or cleaning up code

KafkaIO to read from regex topic

2020-02-24 Thread Maulik Soneji
Hello All, I am currently using Beam version 2.19.0 to read data from Kafka using KafkaIO. Kafka version: 0.11.0.0 My use case is to read all topics from the kafka cluster. Below is the code that reads data from kafka using KafkaIO. KafkaIO.read() .withBootstrapServers(brokers)