RE: Re: KafkaSource consumer group

2023-03-31 Thread Roberts, Ben (Senior Developer) via user
s? I believe > the Flink-way of doing this would be to have one job read the topic, and > then you'd do a stream split if you want to have two different branches of > processing business logic. > > Thanks, > Gordon > > On Thu, Mar 30, 2023 at 9:34 AM Roberts, Ben (Senior D

KafkaSource consumer group

2023-03-30 Thread Roberts, Ben (Senior Developer) via user
Hi, Is there a way to run multiple flink jobs with the same Kafka group.id and have them join the same consumer group? It seems that setting the group.id using KafkaSource.builder().set_group_id() does not have the effect of creating an actual consumer group in Kafka. Running the same flink

apache/flink docker images arm64

2023-02-10 Thread Roberts, Ben (Senior Developer) via user
Hi, Would it be possible for the arm64/v8 architecture images to be published to dockerhub apache/flink:1.16 and 1.16.1 please? I’m aware that the official docker flink image is now published in the arm64 arch, but that image doesn’t include a JDK, so it’d be super helpful to have the

Flink 1.16 arm64/v8 docker images

2023-01-31 Thread Roberts, Ben (Senior Developer) via user
Hi, Is it possible for the arm64/v8 architecture images to be published for >1.16 flink-docker (apache/flink)? I’m aware that the official docker flink image is now published in the arm64 arch, but that image doesn’t include a JDK, so it’d be super helpful to have the apache/flink images

Re: [EXTERNAL] Re: Flink 1.15.3 Docker image

2022-11-30 Thread Roberts, Ben (Senior Developer) via user
7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C3000%7C%7C%7C=X6oOAhYBXsy0aAeZzF%2B%2B1qB4RmF0iMHXoIlMTSvOFzY%3D=0> On Tue, Nov 29, 2022 at 4:28 PM Roberts, Ben (Senior Developer) via user mailto:user@flink.apache.org>> wrote: Hi, Is there anyone able to

Flink 1.15.3 Docker image

2022-11-29 Thread Roberts, Ben (Senior Developer) via user
Hi, Is there anyone able to publish the apache/flink docker image for release 1.15.3? I see that the release was announced on 2022-11-10, and the PR for the 1.15.3 dockerfiles (linked: https://github.com/apache/flink-docker/pull/140) has been approved and merged on 2022-11-25, but it looks