Re: [VOTE] KIP-633: Drop 24 hour default of grace period in Streams

Hi Sophie/Matthias, Is it still possible to roll back the other changes without having to un-deprecate the JoinWindows.of(size) method? On Thu, Aug 19, 2021 at 10:12 PM Sophie Blee-Goldman wrote: > Just to clarify, this only affects the JoinWindows APIs. As Matthias > mentioned this KIP > wil

RE: Kafka Issue

Hi Adam and Luke, Sending the drive for the screenshots. https://onedrive.coca-cola.com/:f:/g/personal/yminagawa_coca-cola_com/ElC-IVU5k3lMkiOCgn3i0g4Bf4EHTWxssur6E5UIkgoC0g?e=xrMlXX Password: kafka All the best, [lingarogroup.com] Roel Angeles Consultant +63 9157163557 roel.ange...@lingarogrou

Re: Kafka Issue

Sorry, I don't have much knowledge on how event Hubs get all the active topics. But at least you can list all available topics in your brokers, or check details of specific topic by these commands. > bin/kafka-topics.sh --list --bootstrap-server localhost:9092 > bin/kafka-topics.sh --describe --t

[jira] [Created] (KAFKA-13220) Group or Group Coordinator logs are misleading when using assign(partitions) method in Consumer API.

nandini created KAFKA-13220: --- Summary: Group or Group Coordinator logs are misleading when using assign(partitions) method in Consumer API. Key: KAFKA-13220 URL: https://issues.apache.org/jira/browse/KAFKA-13220

Re: KIP-769: Connect API to retrieve connector configuration definitions

Hi Chris, You're right, you can achieve the same functionality using the existing validate endpoint. In my mind it was only for validation once you have build a configuration but when used with an empty configuration, it basically serves the same purpose as the proposed new endpoint. I think it's

Re: KIP-769: Connect API to retrieve connector configuration definitions

I think it'd be worth adding a GET version, fwiw. Could be the same handler with just a different spelling maybe. On Fri, Aug 20, 2021, 7:44 AM Mickael Maison wrote: > Hi Chris, > > You're right, you can achieve the same functionality using the > existing validate endpoint. > In my mind it was o

Re: [DISCUSS] KIP-762 Delete Committed Connect Records

Mickael, thanks for taking a look. I wouldn't be opposed to making this a per-connector configuration. I guess each topic-partition is consumed by one WorkerSinkTask, so it should be safe for the worker to truncate such partitions if all associated Connectors opt-in. I think in that case it may ma

[jira] [Created] (KAFKA-13221) Add metric for `PartitionsWithLateTransactionsCount`

Jason Gustafson created KAFKA-13221: --- Summary: Add metric for `PartitionsWithLateTransactionsCount` Key: KAFKA-13221 URL: https://issues.apache.org/jira/browse/KAFKA-13221 Project: Kafka Is

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #416

See Changes: -- [...truncated 489110 lines...] [2021-08-20T18:15:22.034Z] ListOffsetsIntegrationTest > testMaxTimestampOffset() PASSED [2021-08-20T18:15:22.034Z] [2021-08-

[jira] [Resolved] (KAFKA-9938) Fix debug consumer read from follower for older protocol versions

[ https://issues.apache.org/jira/browse/KAFKA-9938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9938. Resolution: Won't Fix I am going to close this issue as "won't fix." Since the new `Fetch`

Re: Failed Unit testings in ReassignPartitionsIntegrationTest

This assertion doesn't seem safe. I opened a PR for a fix. Do you mind taking a look, Luke? David On Thu, Aug 19, 2021 at 12:29 AM Yanwen Lin wrote: > Hi Luke, > > Thanks for your suggestion! I will try to test in in VM/Docker. > > BTW, may I know the exact java/scala version used in your local

Re: Kafka Issue

Microsoft Azure Event Hubs are not Kafka (although they are compatible with Kafka protocol and clients). You may find better answers on the Azure support. On Fri, Aug 20, 2021, 1:06 AM Luke Chen wrote: > Sorry, I don't have much knowledge on how event Hubs get all the active > topics. > But at

Re: [VOTE] KIP-633: Drop 24 hour default of grace period in Streams

@Sophie: thanks for add the details! @Israel: Well, if we roll back (ie, don't add) `JoinWindows.ofTimeDifferenceAndGrace | WithNoGrace()` but we keep `JoinWindow.of(size)` deprecated, than there is no non-deprecated API that allows to specify the join window. So I don't think it is an option? -

[jira] [Resolved] (KAFKA-13218) kafka deleted unexpired message unexpectedly

[ https://issues.apache.org/jira/browse/KAFKA-13218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leiminghany resolved KAFKA-13218. - Resolution: Not A Problem > kafka deleted unexpired message unexpectedly > -