Re: Samza partition hashing relative to other clients

Hi Malcolm, You should be able to override the following producer config for partitioner.class: https://kafka.apache.org/24/documentation.html#producerconfigs This can be done as follows via Samza config systems.system-name.prod

Upcoming release

Hi everyone, Are there any plans to release Samza soon? Really hoping to get the security fixes. Thanks, Stuart

Jackson/Kafka Upgrade PRs

Hi everyone, I have two PRs up for a week or so was hoping someone could look into: Jackson upgrade -> this fixes CVE security issue, due to package name changes cannot dependency manage upgrade this as a client so urgent for me, https://github.com/apache/samza/pull/1464

Travis Build

Hey I raised a PR https://github.com/apache/samza/pull/1456 But the Travis job just seems stuck on queued is this usual? Previously it just timed out . THanks

Re: [VOTE] Apache Samza 1.6.0 RC1

Verified signature. Ran check-all. +1 Stuart > On 13 Jan 2021, at 16:30, Yi Pan wrote: > > Verified signature and sha1. Ran check-all and integration tests. All > passed. > > +1 (binding). > > -Yi > > On Mon, Jan 11, 2021 at 4:08 PM Bharath Kumara Subramanian < > codin.mart...@gmail.com>

Re: Zookeeper and Client upgrade

tickets for update requests like these.> > > Thanks for reporting!> > > -Yi> > > On Fri, Jan 8, 2021 at 9:58 PM Stuart Perks > > wrote:> > > > The Zookeeper version sits at 3.4.6 with 3.6.2 now available bringing> > > security enhanceme

Zookeeper and Client upgrade

The Zookeeper version sits at 3.4.6 with 3.6.2 now available bringing security enhancements. https://github.com/apache/samza/blob/master/gradle/dependency-versions.gradle The client is at 0.8 and has 0.11 available.

Re: SAMZA-2612: Kafka topic naming not supported fully

This can be done using withPhysicalName Closed the JIRA On 2020/12/17 12:19:27, Stuart Perks wrote: > https://issues.apache.org/jira/browse/SAMZA-2612> > > Raised a bug JIRA but wanted to check with the community. Any thoughts would > be great.> > > > The St

Samza Test

I have a Samza application that writes into a table back by a changelog. Is there any way to assert on the data stored in the table using Samza test using the InMemorySystemDescriptor after data has been run into the topology? Thanks

SAMZA-2612: Kafka topic naming not supported fully

https://issues.apache.org/jira/browse/SAMZA-2612 Raised a bug JIRA but wanted to check with the community. Any thoughts would be great. The StreamDescriptor class cannot accept all acceptable formats for Kafka Topic names. StreamDescriptor private static final Pattern STREAM_ID_PATTERN = Pa