Re: [Feature proposal] Java Record Schema inference

2024-04-16 Thread Maciej Szwaja via dev
n regular Java objects. Since I believe that Record classes > expand out into normal classes, we should be able to reuse the existing > code (i.e. JavaFieldSchema.java and PojotUtils.java) with maybe some small > modifications. > > On Mon, Apr 15, 2024 at 8:03 AM Maciej Szwaja via dev

[Feature proposal] Java Record Schema inference

2024-04-15 Thread Maciej Szwaja via dev
Hi team, I'd like to propose a new java sdk extension feature, which is adding support for java record schema inference - see the design doc here: https://docs.google.com/document/d/1zSQ9cnqtVM8ttJEuHBDE6hw4qjUuJy1dpZWB6IBTuOs/edit?usp=sharing In short - adding this extension's jar to the classpa

Re: 2.56.0 release

2024-04-05 Thread Maciej Szwaja via dev
Hi, a nice round version number :) Cheers, Maciej On Thu, Apr 4, 2024 at 3:56 PM Danny McCormick via dev wrote: > Hey everyone, > > On top of running the current 2.55.1 patch release, I'd like to volunteer > as release manager for the 2.56.0 release, which will be cut on April 17. > Please add

Re: Update confluent dependencies version in kafka io

2024-03-19 Thread Maciej Szwaja via dev
gt; https://github.com/apache/beam/pull/30638 > > Thanks for doing this! > > On Fri, Mar 15, 2024 at 3:30 PM Maciej Szwaja via dev > wrote: > >> Hi team, thanks for the answers and an update from me - I've created the >> PR https://github.com/apache/beam/pull/30638

Re: Update confluent dependencies version in kafka io

2024-03-15 Thread Maciej Szwaja via dev
Hi team, thanks for the answers and an update from me - I've created the PR https://github.com/apache/beam/pull/30638 which seems to pass the tests (sometimes they're flaky though, so I didn't manage to get all green in the checks yet), and also I was able to run a pipeline that reads avro records

Update confluent dependencies version in kafka io

2024-03-11 Thread Maciej Szwaja via dev
Hi, This is my first email to this list, hello everyone! I have a question regarding the confluent version dependency that beam, or more specifically kafka io extension, is currently using. Tl;dr is that I'd like to update the confluent library version to something more recent, and was wondering