[jira] [Created] (KAFKA-10823) AdminOperationException has no error code

Lincong Li created KAFKA-10823: -- Summary: AdminOperationException has no error code Key: KAFKA-10823 URL: https://issues.apache.org/jira/browse/KAFKA-10823 Project: Kafka Issue Type: Bug

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #292

See Changes: [github] MINOR: Remove redundant default parameter values in call to LogSegment.open (#9710) -- [...truncated 3.48 MB...]

[jira] [Created] (KAFKA-10822) Force some stdout from downgrade_test.py for Travis

Chia-Ping Tsai created KAFKA-10822: -- Summary: Force some stdout from downgrade_test.py for Travis Key: KAFKA-10822 URL: https://issues.apache.org/jira/browse/KAFKA-10822 Project: Kafka

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #291

See

[jira] [Created] (KAFKA-10821) Send cluster id information with the FetchSnapshot request

Jose Armando Garcia Sancio created KAFKA-10821: -- Summary: Send cluster id information with the FetchSnapshot request Key: KAFKA-10821 URL: https://issues.apache.org/jira/browse/KAFKA-10821

[jira] [Created] (KAFKA-10820) Update start offset and end offset of the replicated log

Jose Armando Garcia Sancio created KAFKA-10820: -- Summary: Update start offset and end offset of the replicated log Key: KAFKA-10820 URL: https://issues.apache.org/jira/browse/KAFKA-10820

[jira] [Created] (KAFKA-10819) The freeze operation should validate the content of the snapshot

Jose Armando Garcia Sancio created KAFKA-10819: -- Summary: The freeze operation should validate the content of the snapshot Key: KAFKA-10819 URL: https://issues.apache.org/jira/browse/KAFKA-10819

[jira] [Resolved] (KAFKA-7819) Trogdor - Improve RoundTripWorker

[ https://issues.apache.org/jira/browse/KAFKA-7819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-7819. - Fix Version/s: 2.2.0 Resolution: Fixed Closing since I noticed the PR was merged. >

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #267

See

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #290

See Changes: [github] KAFKA-10394: Add classes to read and write snapshot for KIP-630 (#9512) -- [...truncated 3.49 MB...]

[jira] [Resolved] (KAFKA-10818) Skip conversion to `Struct` when serializing generated requests/responses

[ https://issues.apache.org/jira/browse/KAFKA-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-10818. - Resolution: Fixed > Skip conversion to `Struct` when serializing generated requests/responses >

[jira] [Created] (KAFKA-10818) Skip conversion to `Struct` when serializing generated requests/responses

Ismael Juma created KAFKA-10818: --- Summary: Skip conversion to `Struct` when serializing generated requests/responses Key: KAFKA-10818 URL: https://issues.apache.org/jira/browse/KAFKA-10818 Project:

Re: [VOTE] KIP-679: Producer will enable the strongest delivery guarantee by default

Thanks, +1 (binding). On Mon, Dec 7, 2020 at 1:40 PM Cheng Tan wrote: > Hi Ismael, > > Yes. Add deprecation warning for `IDEMPOTENT_WRITE` in 3.0 makes sense. > I’ve updated the KIP’s “DEMPOTENT_WRITE Deprecation” section to reflect > your suggestion. Please let me know if you have more

Re: Contributing Avro Kafka Connect converter

I could be wrong but according to https://kafka.apache.org/documentation/#connect_running Avro should be supported out of the box. key.converter - Converter class used to convert between Kafka Connect format and the serialized form that is written to Kafka. This controls the format of the

Re: [VOTE] KIP-679: Producer will enable the strongest delivery guarantee by default

Hi Ismael, Yes. Add deprecation warning for `IDEMPOTENT_WRITE` in 3.0 makes sense. I’ve updated the KIP’s “DEMPOTENT_WRITE Deprecation” section to reflect your suggestion. Please let me know if you have more suggestions. Thanks. Best, - Cheng Tan > On Dec 7, 2020, at 6:42 AM, Ismael Juma

Contributing Avro Kafka Connect converter

Hi, I would like to contribute an Avro converter for Kafka Connect. I described the approach on the Issue, https://issues.apache.org/jira/browse/KAFKA-10715 I am looking for a reviewer who can validate my approach and help commit the change. Is anyone interested in helping me? Thank you!

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #289

See Changes: [github] KAFKA-10811: Correct the MirrorConnectorsIntegrationTest to correctly mask the exit procedures (#9698) [github] KAFKA-10798; Ensure response is delayed for failed SASL

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #266

See Changes: [github] KAFKA-10811: Correct the MirrorConnectorsIntegrationTest to correctly mask the exit procedures (#9698) [github] KAFKA-10798; Ensure response is delayed for failed SASL

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #312

See

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi, Satish, Thanks for the reply. A few more comments below. 5102.2: It seems that both positions can just be int. Another option is to have two methods. Would it be clearer? InputStream fetchLogSegmentData(RemoteLogSegmentMetadata remoteLogSegmentMetadata,

Re: [DISCUSS] KIP-692: Make AdminClient value object constructors public

Sounds like a good idea :) At some point we may want to switch to builders - it gives you more flexibility in how you construct all those objects. But those two changes are unrelated. On Thu, Dec 3, 2020 at 9:30 AM Noa Resare wrote: > > Hi there, > > I finally got around to write up the KIP for

[jira] [Created] (KAFKA-10817) Add clusterId validation to Fetch handling

Jason Gustafson created KAFKA-10817: --- Summary: Add clusterId validation to Fetch handling Key: KAFKA-10817 URL: https://issues.apache.org/jira/browse/KAFKA-10817 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-10816) Connect REST API should have a resource that can be used as a readiness probe

Randall Hauch created KAFKA-10816: - Summary: Connect REST API should have a resource that can be used as a readiness probe Key: KAFKA-10816 URL: https://issues.apache.org/jira/browse/KAFKA-10816

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi Jun, Thanks for your comments. Please find the inline replies below. >605.2 It's rare for the follower to need the remote data. So, the current approach is fine too. Could you document the process of rebuilding the producer state since we can't simply trim the producerState to an offset in the

[jira] [Resolved] (KAFKA-10798) Failed authentication delay doesn't work with some SASL authentication failures

[ https://issues.apache.org/jira/browse/KAFKA-10798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-10798. Reviewer: Manikumar Resolution: Fixed > Failed authentication delay doesn't work

Re: [VOTE] 2.7.0 RC4

Hi Boyang, Thanks for the heads-up; I agree this is a regression for streams and should go into 2.7. Thanks, Bill On Mon, Dec 7, 2020 at 1:00 AM Boyang Chen wrote: > Hey Bill, > > Unfortunately we have found another regression in 2.7 streams, which I have > filed a blocker here

Re: [VOTE] KIP-689: Extend `StreamJoined` to allow more store configs

Thanks all! KIP-689 is accepted with 4 binding votes (Sophie, Guozhang, Matthias, John) and 2 non-binding votes (Bruno, Walker). Cheers, Leah On Fri, Dec 4, 2020 at 10:03 PM John Roesler wrote: > Sorry I missed the discussion, but I just read the KIP and > the discussion. It all looks good to

Re: [VOTE] KIP-679: Producer will enable the strongest delivery guarantee by default

Thanks for the KIP Cheng. One suggestion: should we add the `kafka-acls` deprecation warnings for `IDEMPOTENT_WRITE` in 3.0? That would give time for authorizer implementations to be updated. Ismael On Fri, Dec 4, 2020 at 11:00 AM Cheng Tan wrote: > Hi all, > > I’m proposing a new KIP for

Re: [DISCUSS] KIP-691: Transactional Producer Exception Handling

Thanks Boyang for the KIP! Like Matthias, I do also not know the producer internal well enough to comment on the categorization. However, I think having a super exception (e.g. RetriableException) that encodes if an exception is fatal or not is cleaner, better understandable and less

Re: [VOTE] KIP-679: Producer will enable the strongest delivery guarantee by default

+1 (binding) Thanks for the KIP, Cheng! Regards, Rajini On Mon, Dec 7, 2020 at 6:14 AM Gwen Shapira wrote: > +1 (binding). Awesome suggestion, Cheng. > > On Fri, Dec 4, 2020 at 11:00 AM Cheng Tan wrote: > > > > Hi all, > > > > I’m proposing a new KIP for enabling the strongest delivery

[jira] [Created] (KAFKA-10815) EosTestDriver#verifyAllTransactionFinished should break loop if all partitions are verified

Chia-Ping Tsai created KAFKA-10815: -- Summary: EosTestDriver#verifyAllTransactionFinished should break loop if all partitions are verified Key: KAFKA-10815 URL: https://issues.apache.org/jira/browse/KAFKA-10815