Re: [DISCUSS] KIP-725: Streamlining configurations for TimeWindowedDeserializer.

Thanks John! Yeah I think window.inner.class.deserializer sounds good. Your thoughts @Sophie? Thanks! Sagar. On Fri, Apr 2, 2021 at 5:23 AM John Roesler wrote: > Hi Sagar, > > I think this is a good proposal. > > The only change I might recommend is to change the config to more closely > alig

Re: [VOTE] KIP-720 Deprecate MirrorMaker v1

Hi Ryanne, Thanks for the response. It would be good to have a PR for KIP-382, I agree. Perhaps one possible compromise for KIP-712 would be to make the changes in MM2 first, and then backport them to MM1. I think it's important that when we have a deprecated way of doing something and a non-

Re: [DISCUSS] KIP-729 Custom validation of records on the broker prior to log append

Hi Soumyajit, I believe we've had discussions about proposals similar to this before, although I'm having trouble finding one right now. The issue here is that Record is a private class -- it is not part of any public API, and may change at any time. So we can't expose it in public APIs. bes

Re: [DISCUSS] KIP-712: Shallow Mirroring

Hi, Henry, Thanks for the reply. 3. Regarding EOS, supporting read_committed makes sense. 1. Regarding re-implementing 30 methods. Could we structure the code such that the implementation of most of the methods could be shared? Thanks, Jun On Thu, Apr 1, 2021 at 11:18 PM Henry Cai wrote: >

[jira] [Created] (KAFKA-12607) Allow votes to be granted in resigned state

Jason Gustafson created KAFKA-12607: --- Summary: Allow votes to be granted in resigned state Key: KAFKA-12607 URL: https://issues.apache.org/jira/browse/KAFKA-12607 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-725: Streamlining configurations for TimeWindowedDeserializer.

Hey Sagar, Thanks for picking this up! The proposal looks good to me after Sophie and John's changes. Cheers, Leah On Fri, Apr 2, 2021 at 6:21 AM Sagar wrote: > Thanks John! > > Yeah I think window.inner.class.deserializer sounds good. Your thoughts > @Sophie? > > Thanks! > Sagar. > > > On Fri

Re: [DISCUSS] KIP-725: Streamlining configurations for TimeWindowedDeserializer.

Yeah sure, window.inner.class.deserializer sounds good to me On Fri, Apr 2, 2021 at 11:28 AM Leah Thomas wrote: > Hey Sagar, > > Thanks for picking this up! The proposal looks good to me after Sophie and > John's changes. > > Cheers, > Leah > > On Fri, Apr 2, 2021 at 6:21 AM Sagar wrote: > > >

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #694

See Changes: [github] MINOR: remove KTable.to from the docs (#10464) -- [...truncated 3.69 MB...] AuthorizerIntegrationTest > shouldThrowTransactionalIdAuth

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #90

See Changes: [Matthias J. Sax] MINOR: remove KTable.to from the docs (#10464) -- [...truncated 3.63 MB...] BrokerEndPointTest > testFromJsonV1() STARTED Broker

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

See Changes: [github] MINOR: remove KTable.to from the docs (#10464) -- [...truncated 3.69 MB...] TopicCommandWithZKClientTest > testDescribe() STARTED Topi

[jira] [Resolved] (KAFKA-12312) kafka_2.13:2.6.1 throws NoSuchMethodError when running against scala-sdk-2.13.4

[ https://issues.apache.org/jira/browse/KAFKA-12312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-12312. - Resolution: Duplicate Thanks for the report. Marking this as a duplicate of KAFKA-12357 (which h

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

See Changes: [github] MINOR: remove KTable.to from the docs (#10464) -- [...truncated 7.35 MB...] TransactionsTest > testReadCommittedConsumerShouldNotSeeUnde

[jira] [Created] (KAFKA-12608) Simple identity pipeline sometimes loses data

Jamie Brandon created KAFKA-12608: - Summary: Simple identity pipeline sometimes loses data Key: KAFKA-12608 URL: https://issues.apache.org/jira/browse/KAFKA-12608 Project: Kafka Issue Type: B

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #695

See Changes: [github] KAFKA-12283: disable flaky testMultipleWorkersRejoining to stabilize build (#10408) -- [...truncated 3.69 MB...] AuthorizerIntegration

[jira] [Resolved] (KAFKA-9765) Could not add partitions to transaction due to errors

[ https://issues.apache.org/jira/browse/KAFKA-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9765. -- Resolution: Duplicate > Could not add partitions to transaction due to errors > ---

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

See Changes: [github] KAFKA-12283: disable flaky testMultipleWorkersRejoining to stabilize build (#10408) -- [...truncated 3.67 MB...] LogValidatorTest > tes

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

See Changes: [github] KAFKA-12283: disable flaky testMultipleWorkersRejoining to stabilize build (#10408) -- [...truncated 3.69 MB...] KafkaZkClientTest > t

[jira] [Resolved] (KAFKA-3968) fsync() is not called on parent directory when new FileMessageSet is flushed to disk

[ https://issues.apache.org/jira/browse/KAFKA-3968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-3968. Fix Version/s: 3.0.0 Assignee: Cong Ding Resolution: Fixed Merged to trunk. Thanks Cong for

[jira] [Created] (KAFKA-12609) Rewrite ListOffsets using AdminApiDriver

dengziming created KAFKA-12609: -- Summary: Rewrite ListOffsets using AdminApiDriver Key: KAFKA-12609 URL: https://issues.apache.org/jira/browse/KAFKA-12609 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-12610) Resources on classpath break PluginClassLoader isolation

Nigel Liang created KAFKA-12610: --- Summary: Resources on classpath break PluginClassLoader isolation Key: KAFKA-12610 URL: https://issues.apache.org/jira/browse/KAFKA-12610 Project: Kafka Issue

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

Hi Sophie, Making the default to "cooperative-sticky, range" is a smart idea, to ensure we can at least fall back to rangeAssignor if consumers are not following our recommended upgrade path. I updated the KIP accordingly. Hi Chris, No problem, I updated the KIP to include the change in Connect.

[jira] [Resolved] (KAFKA-12599) Remove deprecated --zookeeper in preferredReplicaLeaderElectionCommand

[ https://issues.apache.org/jira/browse/KAFKA-12599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-12599. --- Resolution: Duplicate > Remove deprecated --zookeeper in preferredReplicaLeaderElectionCommand > ---

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

See Changes: [github] KAFKA-3968: fsync the parent directory of a segment file when the file is created (#10405) -- [...truncated 3.72 MB...] KafkaZkClient

[jira] [Resolved] (KAFKA-12600) Remove deprecated config value `default` for client config `client.dns.lookup`

[ https://issues.apache.org/jira/browse/KAFKA-12600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-12600. - Resolution: Fixed > Remove deprecated config value `default` for client config `client.dns.looku

[jira] [Resolved] (KAFKA-12592) Remove deprecated LogConfig.Compact

[ https://issues.apache.org/jira/browse/KAFKA-12592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-12592. - Resolution: Fixed https://github.com/apache/kafka/pull/10451 > Remove deprecated LogConfig.Comp

[jira] [Resolved] (KAFKA-8009) Uppgrade Jenkins job Gradle version from 4.10.2 to 5.x

[ https://issues.apache.org/jira/browse/KAFKA-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-8009. Resolution: Fixed This was fixed a while back. > Uppgrade Jenkins job Gradle version from 4.10.2 t

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #696

See Changes: [github] KAFKA-3968: fsync the parent directory of a segment file when the file is created (#10405) -- [...truncated 3.70 MB...] AuthorizerInt

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

See Changes: [github] KAFKA-3968: fsync the parent directory of a segment file when the file is created (#10405) -- [...truncated 3.71 MB...] LogValidatorTe