Abacn commented on PR #36124: URL: https://github.com/apache/beam/pull/36124#issuecomment-3299429917
> > Would this change make this branch no longer accessible? > > https://github.com/apache/beam/blob/6ef60bbf03a89c79dbad5009733eb6438c820f1c/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java#L1848 > > I think users could override to zero to get no bucketing. Do you think that's okay? We can leave for now as a way to achieve the original behavior in case there are any edge cases? I see, maybe add a javadoc in (withRedistributeNumKeys) noting the default number of buckets (2^15) and set to 0 to disable bucketing? https://github.com/apache/beam/pull/36124/files#diff-ee81e93a5689a74087a1451bfaac1ef921b0b0254830b9e5450a0a5b6cf2c227R2687 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
