Jenkins build is back to normal : kafka-2.3-jdk8 #48

See

Build failed in Jenkins: kafka-trunk-jdk8 #3714

See Changes: [github] MINOR: Fix transient failure in [github] MINOR: Increase timeouts to 30 seconds (#6852) -- [...truncated 4.91 MB...]

[jira] [Created] (KAFKA-8522) Tombstones can survive forever

Evelyn Bayes created KAFKA-8522: --- Summary: Tombstones can survive forever Key: KAFKA-8522 URL: https://issues.apache.org/jira/browse/KAFKA-8522 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-8349) Add Windows batch files corresponding to kafka-delete-records.sh and kafka-log-dirs.sh

[ https://issues.apache.org/jira/browse/KAFKA-8349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kengo Seki resolved KAFKA-8349. --- Resolution: Fixed Closing this since it's been already merged. Thanks [~hachikuji]! > Add Windows

[jira] [Resolved] (KAFKA-8333) Load high watermark checkpoint only once when handling LeaderAndIsr requests

[ https://issues.apache.org/jira/browse/KAFKA-8333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8333. Resolution: Fixed Fix Version/s: 2.4.0 > Load high watermark checkpoint only once

Kafka streams issue

Hello, I'm working with the kafka streams api and am running into issues where I subscribe to multiple topics and the consumer just hangs. It has a unique application.id and I can see in kafka that the consumer group has been created, but when I describe the group, I'll get: consumer group X has

Jenkins build is back to normal : kafka-trunk-jdk11 #617

See

Build failed in Jenkins: kafka-trunk-jdk8 #3713

See Changes: [matthias] KAFKA-7315 DOCS update TOC internal links serdes all versions (#6875) -- [...truncated 4.76 MB...]

Build failed in Jenkins: kafka-2.3-jdk8 #47

See Changes: [matthias] KAFKA-7315 DOCS update TOC internal links serdes all versions (#6875) -- [...truncated 2.76 MB...] kafka.utils.SchedulerTest >

Jenkins build is back to normal : kafka-2.1-jdk8 #203

See

Build failed in Jenkins: kafka-2.0-jdk8 #275

See Changes: [matthias] KAFKA-7315 DOCS update TOC internal links serdes all versions (#6875) -- [...truncated 889.68 KB...] kafka.controller.ReplicaStateMachineTest >

[jira] [Created] (KAFKA-8521) Client unable to get a complete transaction set of messages using a single poll call

Boris Rybalkin created KAFKA-8521: - Summary: Client unable to get a complete transaction set of messages using a single poll call Key: KAFKA-8521 URL: https://issues.apache.org/jira/browse/KAFKA-8521

Re: [VOTE] KIP-476: Add Java AdminClient interface

Hi Andy, This is a big change, and I don't think there has been a lot of discussion about the pros and cons. What specific benefits do we get from transitioning to using an interface rather than an abstract class? If we are serious about doing this, would it be cleaner to just change

[jira] [Created] (KAFKA-8520) TimeoutException in client side doesn't have stack trace

Shixiong Zhu created KAFKA-8520: --- Summary: TimeoutException in client side doesn't have stack trace Key: KAFKA-8520 URL: https://issues.apache.org/jira/browse/KAFKA-8520 Project: Kafka Issue

Build failed in Jenkins: kafka-trunk-jdk11 #616

See Changes: [matthias] KAFKA-7315 DOCS update TOC internal links serdes all versions (#6875) -- [...truncated 2.50 MB...]

Re: [kafka-clients] [VOTE] 2.3.0 RC1

Hey Colin and Jason, I would like to mention that https://issues.apache.org/jira/browse/KAFKA-8500 could also potentially be a blocker. The PR is ready for review: https://github.com/apache/kafka/pull/6899 Boyang From: Colin McCabe Sent: Tuesday, June 11,

Jenkins build is back to normal : kafka-1.0-jdk7 #273

See

[jira] [Created] (KAFKA-8519) Trogdor should support network degradation

David Arthur created KAFKA-8519: --- Summary: Trogdor should support network degradation Key: KAFKA-8519 URL: https://issues.apache.org/jira/browse/KAFKA-8519 Project: Kafka Issue Type:

Re: [VOTE] KIP-476: Add Java AdminClient interface

Hmmm... So the new interface, returns an instance of a class that implements the interface. This sounds a little bit like an anti-pattern? Shouldn't interfaces actually not know anything about classes that implement the interface? -Matthias On 6/10/19 11:22 AM, Andy Coates wrote: >

Re: [VOTE] KIP-476: Add Java AdminClient interface

`AdminClient` would be deprecated purely because it would no longer serve any purpose and would be virtually empty, getting all of its implementation from the new interfar. It would be nice to remove this from the API at the next major version bump, hence the need to deprecate.

[jira] [Resolved] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7315. Resolution: Fixed > Streams serialization docs contain a broken link for Avro >

Re: [kafka-clients] [VOTE] 2.3.0 RC1

Hi all, Please take a look at the release candidate. We haven't found any blockers yet! best, Colin On Thu, Jun 6, 2019, at 14:45, Jason Gustafson wrote: > Hi Colin, > > After looking at these issues a little more, we do not believe they are > blockers for the release. > > Thanks, > Jason >

[jira] [Created] (KAFKA-8518) Update GitHub repo description to make it obvious that it is not a "mirror" anymore

Etienne Neveu created KAFKA-8518: Summary: Update GitHub repo description to make it obvious that it is not a "mirror" anymore Key: KAFKA-8518 URL: https://issues.apache.org/jira/browse/KAFKA-8518

Re: [DISCUSS] KIP-466: Add support for List serialization and deserialization

Bump > On May 24, 2019, at 2:09 PM, Development wrote: > > Hey, > > - did we consider to make the return type (ie, ArrayList, vs > LinkesList) configurable or encode it the serialized bytes? > > Not sure about this one. Could you elaborate? > > - atm the size of each element is encoded

How spark structured streaming consumers initiated and invoked while reading multi-partitioned kafka topics?

Hi, Any suggestions regarding below issue? https://stackoverflow.com/questions/56524921/how-spark-structured-streaming-consumers-initiated-and-invoked-while-reading-mul Thanks, Shyam

Re: [VOTE] KIP-434: Dead replica fetcher and log cleaner metrics

+1 (non-binding). Thanks for the KIP! On Thu, Jun 6, 2019 at 8:12 PM Andrew Schofield wrote: > +1 (non-binding) > > Andrew > > On 06/06/2019, 15:15, "Ryanne Dolan" wrote: > > +1 (non-binding) > > Thanks > Ryanne > > On Wed, Jun 5, 2019, 9:31 PM Satish Duggana > wrote: > >

Re: [DISCUSS] KIP-467: Augment ProduceResponse error messaging

This KIP is inline with KIP-334 in which it's proposed that the consumer will throw FaultyRecordException with corrupt/in-operative record offset and topic-partition on encountering the invalid record. In this KIP

[jira] [Created] (KAFKA-8517) A lot of WARN messages in kafka log "Received a PartitionLeaderEpoch assignment for an epoch < latestEpoch:

Jacek Żoch created KAFKA-8517: - Summary: A lot of WARN messages in kafka log "Received a PartitionLeaderEpoch assignment for an epoch < latestEpoch: Key: KAFKA-8517 URL:

[jira] [Created] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

Richard Yu created KAFKA-8516: - Summary: Consider allowing all replicas to have read/write permissions Key: KAFKA-8516 URL: https://issues.apache.org/jira/browse/KAFKA-8516 Project: Kafka Issue

Re: Permission to create a KIP

Done. On 6/9/19 5:53 AM, Gowtham Gutha wrote: > Hello, > My user confluence user id is gowthamgutha Is it possible to grant KIP > permission to me? > > Regards,Gowtham > signature.asc Description: OpenPGP digital signature