[jira] [Created] (KAFKA-9521) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdEmptyGroup

Sophie Blee-Goldman created KAFKA-9521: -- Summary: Flaky Test DeleteConsumerGroupsTest#testDeleteCmdEmptyGroup Key: KAFKA-9521 URL: https://issues.apache.org/jira/browse/KAFKA-9521 Project: Kafka

[jira] [Resolved] (KAFKA-8737) TaskMigrated Exception while rebalancing kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8737. -- Assignee: Guozhang Wang (was: Bill Bejeck) Resolution: Duplicate > TaskMigrated

Re: [KAFKA-557] Add emit on change support for Kafka Streams

Hi all, I've had just a few thoughts regarding the forwarding of >. As Matthias already mentioned, there are two separate priorities by which we can judge this KIP: 1. A optimization perspective: In this case, the user would prefer the impact of this KIP to be as minimal as possible. By such

[jira] [Resolved] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8940. Resolution: Fixed Nevermind. The test is fine. The PR broke the test. Can reproduce it

[jira] [Created] (KAFKA-9520) Deprecate ZooKeeper access for kafka-reassign-partitions.sh

Sanjana Kaundinya created KAFKA-9520: Summary: Deprecate ZooKeeper access for kafka-reassign-partitions.sh Key: KAFKA-9520 URL: https://issues.apache.org/jira/browse/KAFKA-9520 Project: Kafka

[jira] [Created] (KAFKA-9519) Deprecate ZooKeeper access for kafka-configs.sh

Sanjana Kaundinya created KAFKA-9519: Summary: Deprecate ZooKeeper access for kafka-configs.sh Key: KAFKA-9519 URL: https://issues.apache.org/jira/browse/KAFKA-9519 Project: Kafka

Re: [VOTE] KIP-518: Allow listing consumer groups per state

Hi Mickael, Thanks for the KIP. I left a comment on the DISCUSS thread as well. best, Colin On Thu, Feb 6, 2020, at 08:58, Mickael Maison wrote: > Hi Manikumar, > > I believe I've answered David's comments in the DISCUSS thread. > Thanks > > On Wed, Jan 15, 2020 at 10:15 AM Manikumar

Re: [DISCUSS] KIP-518: Allow listing consumer groups per state

Hi Mickael, Can you please specify what the result is when a newer client tries to use this on an older broker? Does that result in an UnsupportedVersionException? I would prefer an Optional in the Java API so that “show all groups” can be EMPTY. best, Colin On Mon, Jan 27, 2020, at 07:53,

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

See Changes: [github] MINOR: Update authorization primitives in security.html (#7508) -- [...truncated 2.95 MB...] kafka.log.ProducerStateManagerTest >

[jira] [Created] (KAFKA-9518) NullPointerException on out-of-order topologies

Murilo Tavares created KAFKA-9518: - Summary: NullPointerException on out-of-order topologies Key: KAFKA-9518 URL: https://issues.apache.org/jira/browse/KAFKA-9518 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

Paul Snively created KAFKA-9517: --- Summary: KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On Key: KAFKA-9517 URL: https://issues.apache.org/jira/browse/KAFKA-9517

Re: [VOTE] KIP-545 support automated consumer offset sync across clusters in MM 2.0

+1 (non-binding) Thanks for the KIP. On 06/02/2020, 17:06, "Edoardo Comar" wrote: +1 (non-binding) thanks for the KIP ! On Tue, 14 Jan 2020 at 13:57, Navinder Brar wrote: > +1 (non-binding) > Navinder > On Tuesday, 14 January, 2020, 07:24:02 pm IST,

[jira] [Created] (KAFKA-9516) Flaky Test PlaintextProducerSendTest#testNonBlockingProducer

Matthias J. Sax created KAFKA-9516: -- Summary: Flaky Test PlaintextProducerSendTest#testNonBlockingProducer Key: KAFKA-9516 URL: https://issues.apache.org/jira/browse/KAFKA-9516 Project: Kafka

[jira] [Reopened] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8940: Reopening. Failed again: 

Re: [VOTE] KIP-545 support automated consumer offset sync across clusters in MM 2.0

+1 (non-binding) thanks for the KIP ! On Tue, 14 Jan 2020 at 13:57, Navinder Brar wrote: > +1 (non-binding) > Navinder > On Tuesday, 14 January, 2020, 07:24:02 pm IST, Ryanne Dolan < > ryannedo...@gmail.com> wrote: > > Bump. We've got 4 non-binding and one binding vote. > > Ryanne > > On

Re: [VOTE] KIP-518: Allow listing consumer groups per state

Hi Manikumar, I believe I've answered David's comments in the DISCUSS thread. Thanks On Wed, Jan 15, 2020 at 10:15 AM Manikumar wrote: > > Hi Mickael, > > Thanks for the KIP. Can you respond to the comments from David on discuss > thread? > > Thanks,

Re: [VOTE] KIP-409: Allow creating under-replicated topics and partitions

I have not seen any new feedback nor votes. Bumping this thread again On Mon, Jan 27, 2020 at 3:55 PM Mickael Maison wrote: > > Hi, > > We are now at 4 non-binding votes but still no binding votes. > I have not seen any outstanding questions in the DISCUSS thread. If > you have any feedback,

[jira] [Created] (KAFKA-9515) Upgrade ZooKeeper to 3.5.7

Ismael Juma created KAFKA-9515: -- Summary: Upgrade ZooKeeper to 3.5.7 Key: KAFKA-9515 URL: https://issues.apache.org/jira/browse/KAFKA-9515 Project: Kafka Issue Type: Improvement

Re: Mistake in official documentation ?

Thanks for your quick feedback. Here is a link to the hosted screenshot https://we.tl/t-TDiRc7jOmV Regards, Fares On Thu, Feb 6, 2020 at 5:16 PM Adam Bellemare wrote: > Screenshot didn't arrive for me - you may need to host it in an image site > (ie: imgur), not sure if the mailing list

Re: Mistake in official documentation ?

Screenshot didn't arrive for me - you may need to host it in an image site (ie: imgur), not sure if the mailing list will allow it to be attached. It could very well be a mistake. highlight it and send it to dev@kafka.apache.org and if it is, we'll make a ticket and address it. On Thu, Feb 6,

Re: [DISCUSS] KIP-552: Add interface to handle unused config

INFO is the default log level, and while it looks less "alarming" than WARN, users will still see it and in my experience, they will worry that something is wrong anyway.  Or if INFO isn't the default, users won't see it, so it is no different from debug and we are left with no way of warning

Mistake in official documentation ?

Hello, While going through the official docs https://kafka.apache.org/documentation/#messageformat If I'm not wrong, I believe there is a mismatch between description of a segment and the diagram illustrating the concept. I pointed out the issue in the attached screenshot. Didn't really know

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

See Changes: [github] KAFKA-8164: Add support for retrying failed (#8019) [github] KAFKA-9447: Add new customized EOS model example (#8031) -- [...truncated 2.38 MB...]

Re: [DISCUSS] : KIP-562: Allow fetching a key from a single partition rather than iterating over all the stores on an instance

Hi, While implementing 562, we have decided to rename StoreQueryParams -> StoreQueryParameters. I have updated the PR and confluence. Please share if anyone has feedback on it. Thanks & Regards, Navinder Pal Singh Brar On Friday, 24 January, 2020, 08:45:15 am IST, Navinder Brar wrote:

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Hi John, In out case it wont help, since we are running instance per partition and even with summary only we get 32 warnings per rollout. Hi Gwen, Thanks for you reply, I understand and share your concern, I also mentioned it earlier in the thread. Do you think it will work if we change DEBUG

[jira] [Created] (KAFKA-9514) The protocol generator generated useless condition when a field is made nullable and flexible version is used

David Jacot created KAFKA-9514: -- Summary: The protocol generator generated useless condition when a field is made nullable and flexible version is used Key: KAFKA-9514 URL: