[jira] [Commented] (KAFKA-9435) Replace DescribeLogDirs request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016850#comment-17016850 ] ASF GitHub Bot commented on KAFKA-9435: --- tombentley commented on pull request #7972

[jira] [Created] (KAFKA-9443) Producer Can Fail with NPE

David Mollitor created KAFKA-9443: - Summary: Producer Can Fail with NPE Key: KAFKA-9443 URL: https://issues.apache.org/jira/browse/KAFKA-9443 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-9423) Refine layout of configuration options on website and make individual settings directly linkable

[ https://issues.apache.org/jira/browse/KAFKA-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017063#comment-17017063 ] Sönke Liebau commented on KAFKA-9423: - Thinking this a little further, is there any a

[jira] [Updated] (KAFKA-9424) Using AclCommand,avoid call the global method loadcache in SimpleAclAuthorizer

[ https://issues.apache.org/jira/browse/KAFKA-9424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Lu updated KAFKA-9424: - Reviewer: Ismael Juma (was: Guangyuan Wang) > Using AclCommand,avoid call the global method loadcache in

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017077#comment-17017077 ] highluck commented on KAFKA-9042: - [~mjsax]  [~bchen225242] I create a KIP, I modified

[jira] [Comment Edited] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017077#comment-17017077 ] highluck edited comment on KAFKA-9042 at 1/16/20 4:18 PM: -- [~mjs

[jira] [Commented] (KAFKA-9440) Add ConsumerGroupCommand to delete static members

[ https://issues.apache.org/jira/browse/KAFKA-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017080#comment-17017080 ] highluck commented on KAFKA-9440: - [~bchen225242] Can I take this ticket with me? > Add

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017287#comment-17017287 ] Raman Gupta commented on KAFKA-8803: Very very strange. Following up on my last messa

[jira] [Created] (KAFKA-9444) Cannot connect to zookeeper after updating the kafka config

Rishabh Bohra created KAFKA-9444: Summary: Cannot connect to zookeeper after updating the kafka config Key: KAFKA-9444 URL: https://issues.apache.org/jira/browse/KAFKA-9444 Project: Kafka Is

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017311#comment-17017311 ] Raman Gupta commented on KAFKA-8803: Is it possible this is related in the opposite d

[jira] [Updated] (KAFKA-9444) Cannot connect to zookeeper after updating the kafka config

[ https://issues.apache.org/jira/browse/KAFKA-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rishabh Bohra updated KAFKA-9444: - Description: h4. *Issue:* While connecting the kafka with zookeeper at a custom path, in the bro

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017315#comment-17017315 ] highluck commented on KAFKA-7658: - [~mjsax] If I am not ready now, can I take my ticket

[jira] [Issue Comment Deleted] (KAFKA-9440) Add ConsumerGroupCommand to delete static members

[ https://issues.apache.org/jira/browse/KAFKA-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-9440: Comment: was deleted (was: [~bchen225242] Can I take this ticket with me?) > Add ConsumerGroupCommand to

[jira] [Created] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

Navinder Brar created KAFKA-9445: Summary: Allow fetching a key from a single partition rather than iterating over all the stores on an instance Key: KAFKA-9445 URL: https://issues.apache.org/jira/browse/KAFKA-944

[jira] [Updated] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navinder Brar updated KAFKA-9445: - Labels: (was: kip-535) > Allow fetching a key from a single partition rather than iterating ove

[jira] [Updated] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navinder Brar updated KAFKA-9445: - Description: (was: Currently when expanding the KS cluster, the new node's partitions will be

[jira] [Updated] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navinder Brar updated KAFKA-9445: - Description: Whenever a call is made to get a particular key from a Kafka Streams instance, curre

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017370#comment-17017370 ] Matthias J. Sax commented on KAFKA-9259: Could KAFKA-8317 be a duplicate? > supp

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017385#comment-17017385 ] Matthias J. Sax commented on KAFKA-9042: Did you read how the KIP process works?

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017388#comment-17017388 ] Matthias J. Sax commented on KAFKA-7658: Not sure what your question is? > Add K

[jira] [Created] (KAFKA-9446) Integration test library should provide utilities to assert connector state

Chris Egerton created KAFKA-9446: Summary: Integration test library should provide utilities to assert connector state Key: KAFKA-9446 URL: https://issues.apache.org/jira/browse/KAFKA-9446 Project: Ka

[jira] [Commented] (KAFKA-9235) Transaction state not cleaned up following StopReplica request

[ https://issues.apache.org/jira/browse/KAFKA-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017517#comment-17017517 ] ASF GitHub Bot commented on KAFKA-9235: --- hachikuji commented on pull request #7963:

[jira] [Resolved] (KAFKA-8832) We should limit the maximum size read by a fetch request on the kafka server.

[ https://issues.apache.org/jira/browse/KAFKA-8832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8832. Resolution: Fixed This is resolved by https://cwiki.apache.org/confluence/display/KAFKA/KI

[jira] [Updated] (KAFKA-8721) Metrics library upgrade

[ https://issues.apache.org/jira/browse/KAFKA-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mario Molina updated KAFKA-8721: Affects Version/s: (was: 2.3.0) 2.4.0 > Metrics library upgrade > --

[jira] [Updated] (KAFKA-8721) Metrics library upgrade

[ https://issues.apache.org/jira/browse/KAFKA-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mario Molina updated KAFKA-8721: Affects Version/s: 2.5.0 > Metrics library upgrade > --- > > Ke

[jira] [Commented] (KAFKA-9431) Expose API in KafkaStreams to fetch all local offset lags

[ https://issues.apache.org/jira/browse/KAFKA-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017532#comment-17017532 ] ASF GitHub Bot commented on KAFKA-9431: --- vvcephei commented on pull request #7961:

[jira] [Resolved] (KAFKA-9428) Expose standby information in KafkaStreams via queryMetadataForKey API

[ https://issues.apache.org/jira/browse/KAFKA-9428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9428. - Resolution: Fixed > Expose standby information in KafkaStreams via queryMetadataForKey API >

[jira] [Resolved] (KAFKA-9429) Allow ability to control whether stale reads out of state stores are desirable

[ https://issues.apache.org/jira/browse/KAFKA-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9429. - Resolution: Fixed > Allow ability to control whether stale reads out of state stores are desirabl

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Description: Right now, we use _endOffsets_ of the source topic for the computation. Since the sou

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Priority: Blocker (was: Major) > Tighten up lag estimates when source topic optimization is on >

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Affects Version/s: 2.5.0 > Tighten up lag estimates when source topic optimization is on > ---

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Fix Version/s: (was: 2.5.0) > Tighten up lag estimates when source topic optimization is on >

[jira] [Resolved] (KAFKA-9235) Transaction state not cleaned up following StopReplica request

[ https://issues.apache.org/jira/browse/KAFKA-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9235. Fix Version/s: 2.4.1 Resolution: Fixed > Transaction state not cleaned up following

[jira] [Assigned] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9430: --- Assignee: John Roesler (was: Vinoth Chandar) > Tighten up lag estimates when source topic o

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Description: Right now, we use _endOffsets_ of the source topic for the computation. For "optimize

[jira] [Assigned] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9430: --- Assignee: (was: John Roesler) > Tighten up lag estimates when source topic optimization

[jira] [Resolved] (KAFKA-9431) Expose API in KafkaStreams to fetch all local offset lags

[ https://issues.apache.org/jira/browse/KAFKA-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9431. - Resolution: Fixed > Expose API in KafkaStreams to fetch all local offset lags > -

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Parent: (was: KAFKA-6144) Issue Type: Improvement (was: Sub-task) > Tighten up lag est

[jira] [Updated] (KAFKA-6144) Allow serving interactive queries from in-sync Standbys

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-6144: Fix Version/s: 2.5.0 > Allow serving interactive queries from in-sync Standbys > --

[jira] [Resolved] (KAFKA-6144) Allow serving interactive queries from in-sync Standbys

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-6144. - Resolution: Fixed > Allow serving interactive queries from in-sync Standbys > ---

[jira] [Assigned] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinoth Chandar reassigned KAFKA-9430: - Assignee: Vinoth Chandar > Tighten up lag estimates when source topic optimization is on

[jira] [Commented] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017570#comment-17017570 ] Vinoth Chandar commented on KAFKA-9430: --- [~vvcephei] , is there a Jira for the refa

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017571#comment-17017571 ] highluck commented on KAFKA-9042: - [~mjsax] Thank you for your reply   Sorry. It was

[jira] [Commented] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017575#comment-17017575 ] Matthias J. Sax commented on KAFKA-9042: All good :) Nothing to worry about. We a

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017671#comment-17017671 ] John Roesler commented on KAFKA-9259: - Ah, yes, it’s the same issue. Bummer we didn’t

[jira] [Commented] (KAFKA-9441) Refactor commit logic

[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017673#comment-17017673 ] ASF GitHub Bot commented on KAFKA-9441: --- mjsax commented on pull request #7977: KAF

[jira] [Updated] (KAFKA-9444) Cannot connect to zookeeper after updating the kafka config

[ https://issues.apache.org/jira/browse/KAFKA-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rishabh Bohra updated KAFKA-9444: - Description: h4. *Issue:* While connecting the kafka with zookeeper at a custom path, in the bro

[jira] [Updated] (KAFKA-9444) Cannot connect to zookeeper after updating the kafka config

[ https://issues.apache.org/jira/browse/KAFKA-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rishabh Bohra updated KAFKA-9444: - External issue URL: https://stackoverflow.com/questions/59592518/kafka-broker-doesnt-find-cluster

[jira] [Created] (KAFKA-9447) Add examples for EOS standalone and group mode under kafka/examples

Boyang Chen created KAFKA-9447: -- Summary: Add examples for EOS standalone and group mode under kafka/examples Key: KAFKA-9447 URL: https://issues.apache.org/jira/browse/KAFKA-9447 Project: Kafka

[jira] [Created] (KAFKA-9448) Meta data for topic

Pradeep Bansal created KAFKA-9448: - Summary: Meta data for topic Key: KAFKA-9448 URL: https://issues.apache.org/jira/browse/KAFKA-9448 Project: Kafka Issue Type: Improvement Repo

[jira] [Updated] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navinder Brar updated KAFKA-9445: - Labels: https://cwiki.apache.org/confluence/display/KAFKA/KIP-562%3A+Allow+fetching+a+key+from+a+

[jira] [Updated] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navinder Brar updated KAFKA-9445: - Labels: KIP-562 (was: https://cwiki.apache.org/confluence/display/KAFKA/KIP-562%3A+Allow+fetchin

[jira] [Commented] (KAFKA-9356) Potential data loss in InMemoryWindowStore and InMemorySessionStore

[ https://issues.apache.org/jira/browse/KAFKA-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017748#comment-17017748 ] Sophie Blee-Goldman commented on KAFKA-9356: As [~bchen225242] said, Streams

[jira] [Resolved] (KAFKA-9356) Potential data loss in InMemoryWindowStore and InMemorySessionStore

[ https://issues.apache.org/jira/browse/KAFKA-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9356. Resolution: Not A Problem > Potential data loss in InMemoryWindowStore and InMemory

[jira] [Updated] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leibo updated KAFKA-8532: - Description: We have observed a serious deadlock between controller-event-thead and zk-session-expirey-handle th