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...]

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...]

[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

[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

[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

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...]

[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 >

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] [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

[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] [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

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 >

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 >

[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-jdk15 #695

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

[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:

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 >

[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

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

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

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 >

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: > > >

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

[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

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: >

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.

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

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 >

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

See Changes: [github] MINOR: support ImplicitLinkedHashCollection#sort (#10456) [github] MONOR: Remove redudant LocalLogManager (#10325) -- [...truncated

Re: [DISCUSS] KIP-712: Shallow Mirroring

Tom, I don't think we need to refactor the Consumer/Producer class hierarchy for this KIP. If we introduce a separate class for BatchConsumer, there are more than 30 methods in Consumer interface this new class needs to implement and the implementation would be exactly the same as KafkaConsumer.

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

See Changes: [github] MONOR: Remove redudant LocalLogManager (#10325) -- [...truncated 7.38 MB...] BrokerEndPointTest > testBrokerEndpointFromUri() STARTED