[jira] [Commented] (KAFKA-6538) Enhance ByteStore exceptions with more context information

[ https://issues.apache.org/jira/browse/KAFKA-6538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16496089#comment-16496089 ] ASF GitHub Bot commented on KAFKA-6538: --- jadireddi closed pull request #4846: KAFKA-6538: Fixed

[jira] [Created] (KAFKA-6973) setting invalid timestamp causes Kafka broker restart to fail

Paul Brebner created KAFKA-6973: --- Summary: setting invalid timestamp causes Kafka broker restart to fail Key: KAFKA-6973 URL: https://issues.apache.org/jira/browse/KAFKA-6973 Project: Kafka

[jira] [Commented] (KAFKA-6538) Enhance ByteStore exceptions with more context information

[ https://issues.apache.org/jira/browse/KAFKA-6538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16496038#comment-16496038 ] ASF GitHub Bot commented on KAFKA-6538: --- jadireddi opened a new pull request #5103: KAFKA-6538:

[jira] [Commented] (KAFKA-1614) Partition log directory name and segments information exposed via JMX

[ https://issues.apache.org/jira/browse/KAFKA-1614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16496034#comment-16496034 ] ASF GitHub Bot commented on KAFKA-1614: --- everpcpc opened a new pull request #5102: KAFKA-1614:

[jira] [Updated] (KAFKA-6972) Kafka ACL does not work expected with wildcard

[ https://issues.apache.org/jira/browse/KAFKA-6972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Soyee Deng updated KAFKA-6972: -- Description: Just started with Confluent 3.3 platform and Kafka 0.11 having SSL as transportation

[jira] [Updated] (KAFKA-6972) Kafka ACL does not work expected with wildcard

[ https://issues.apache.org/jira/browse/KAFKA-6972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Soyee Deng updated KAFKA-6972: -- Description: Just started with Confluent 3.3 platform and Kafka 0.11 with SSL as transportation

[jira] [Created] (KAFKA-6972) Kafka ACL does not work expected with wildcard

Soyee Deng created KAFKA-6972: - Summary: Kafka ACL does not work expected with wildcard Key: KAFKA-6972 URL: https://issues.apache.org/jira/browse/KAFKA-6972 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6082) consider fencing zookeeper updates with controller epoch zkVersion

[ https://issues.apache.org/jira/browse/KAFKA-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495880#comment-16495880 ] ASF GitHub Bot commented on KAFKA-6082: --- hzxa21 opened a new pull request #5101: KAFKA-6082: Fence

[jira] [Updated] (KAFKA-6971) Passing in help flag to kafka-console-producer should print arg options

[ https://issues.apache.org/jira/browse/KAFKA-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yeva Byzek updated KAFKA-6971: -- Description: {{kafka-console-consumer --help}} prints "help is not a recognized option" as well as

[jira] [Updated] (KAFKA-6971) Passing in help flag to kafka-console-producer should print arg options

[ https://issues.apache.org/jira/browse/KAFKA-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yeva Byzek updated KAFKA-6971: -- Summary: Passing in help flag to kafka-console-producer should print arg options (was: Add help flag

[jira] [Created] (KAFKA-6971) Add help flag to kafka-console-producer

Yeva Byzek created KAFKA-6971: - Summary: Add help flag to kafka-console-producer Key: KAFKA-6971 URL: https://issues.apache.org/jira/browse/KAFKA-6971 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6886) Externalize Secrets for Kafka Connect Configurations

[ https://issues.apache.org/jira/browse/KAFKA-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495724#comment-16495724 ] ASF GitHub Bot commented on KAFKA-6886: --- ewencp closed pull request #5068: KAFKA-6886 Externalize

[jira] [Created] (KAFKA-6970) Kafka streams lets the user call init() and close() on a state store, when inside Processors

James Cheng created KAFKA-6970: -- Summary: Kafka streams lets the user call init() and close() on a state store, when inside Processors Key: KAFKA-6970 URL: https://issues.apache.org/jira/browse/KAFKA-6970

[jira] [Assigned] (KAFKA-6961) UnknownTopicOrPartitionException & NotLeaderForPartitionException upon replication of topics.

[ https://issues.apache.org/jira/browse/KAFKA-6961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] praveen reassigned KAFKA-6961: -- Assignee: praveen > UnknownTopicOrPartitionException & NotLeaderForPartitionException upon >

[jira] [Resolved] (KAFKA-4936) Allow dynamic routing of output records

[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4936. Resolution: Fixed > Allow dynamic routing of output records >

[jira] [Commented] (KAFKA-4936) Allow dynamic routing of output records

[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495558#comment-16495558 ] ASF GitHub Bot commented on KAFKA-4936: --- mjsax closed pull request #5018: KAFKA-4936: Add dynamic

[jira] [Commented] (KAFKA-6738) Kafka Connect handling of bad data

[ https://issues.apache.org/jira/browse/KAFKA-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495549#comment-16495549 ] ASF GitHub Bot commented on KAFKA-6738: --- ewencp closed pull request #5065: KAFKA-6738: Implement

[jira] [Updated] (KAFKA-6943) Have option to shutdown KS cleanly if any threads crashes, or if all threads crash

[ https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6943: - Labels: user-experience (was: ) > Have option to shutdown KS cleanly if any threads crashes, or

[jira] [Resolved] (KAFKA-6957) Add getter to AbstractStream class to make internalTopologyBuilder accessible outside of package

[ https://issues.apache.org/jira/browse/KAFKA-6957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6957. -- Resolution: Fixed Fix Version/s: 2.0.0 > Add getter to AbstractStream class to make

[jira] [Assigned] (KAFKA-6957) Add getter to AbstractStream class to make internalTopologyBuilder accessible outside of package

[ https://issues.apache.org/jira/browse/KAFKA-6957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-6957: Assignee: Florian Hussonnois > Add getter to AbstractStream class to make

[jira] [Commented] (KAFKA-6957) Add getter to AbstractStream class to make internalTopologyBuilder accessible outside of package

[ https://issues.apache.org/jira/browse/KAFKA-6957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495524#comment-16495524 ] ASF GitHub Bot commented on KAFKA-6957: --- guozhangwang closed pull request #5085: KAFKA-6957 make

[jira] [Commented] (KAFKA-6953) [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure)

[ https://issues.apache.org/jira/browse/KAFKA-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495388#comment-16495388 ] Flavio Stutz commented on KAFKA-6953: - [~guozhang], you are right on your observations, but doing it

[jira] [Commented] (KAFKA-6941) when passing port = 0 to worker, the advertisedPort still is 0 rather than a random port

[ https://issues.apache.org/jira/browse/KAFKA-6941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495330#comment-16495330 ] Chia-Ping Tsai commented on KAFKA-6941: --- ping for reviews.  > when passing port = 0 to worker, the

[jira] [Resolved] (KAFKA-3834) Consumer should not block in poll on coordinator discovery

[ https://issues.apache.org/jira/browse/KAFKA-3834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3834. Resolution: Fixed Fix Version/s: 2.0.0 Fixed by KIP-266 > Consumer should not

[jira] [Resolved] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5065. Resolution: Fixed Fixed by KIP-266 > AbstractCoordinator.ensureCoordinatorReady() stuck

[jira] [Resolved] (KAFKA-1894) Avoid long or infinite blocking in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-1894. Resolution: Fixed Fixed by KIP-266 (and many subsequent changes which gradually introduced

[jira] [Resolved] (KAFKA-2391) Blocking call such as position(), partitionsFor(), committed() and listTopics() should have a timeout

[ https://issues.apache.org/jira/browse/KAFKA-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2391. Resolution: Fixed Fix Version/s: 2.0.0 Fixed by KIP-266 > Blocking call such as

[jira] [Resolved] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4879. Resolution: Fixed This is addressed by KIP-266. > KafkaConsumer.position may hang forever

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495306#comment-16495306 ] Jun Rao commented on KAFKA-3042: Interesting. Do you have the controller and the state-change log around

[jira] [Resolved] (KAFKA-6608) Add TimeoutException to KafkaConsumer#position()

[ https://issues.apache.org/jira/browse/KAFKA-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6608. Resolution: Fixed Fix Version/s: 2.0.0 > Add TimeoutException to

[jira] [Commented] (KAFKA-6608) Add TimeoutException to KafkaConsumer#position()

[ https://issues.apache.org/jira/browse/KAFKA-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495301#comment-16495301 ] ASF GitHub Bot commented on KAFKA-6608: --- hachikuji closed pull request #5014: [KAFKA-6608] Add

[jira] [Commented] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495278#comment-16495278 ] Matthias J. Sax commented on KAFKA-6906: [~guozhang] I am not sure if I understand why we need to

[jira] [Created] (KAFKA-6969) AdminClient should provide a way to get the version of a node

Charly Molter created KAFKA-6969: Summary: AdminClient should provide a way to get the version of a node Key: KAFKA-6969 URL: https://issues.apache.org/jira/browse/KAFKA-6969 Project: Kafka

[jira] [Comment Edited] (KAFKA-5588) Remove deprecated new-consumer option for tools

[ https://issues.apache.org/jira/browse/KAFKA-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495006#comment-16495006 ] Paolo Patierno edited comment on KAFKA-5588 at 5/30/18 10:50 AM: -

[jira] [Commented] (KAFKA-5588) Remove deprecated new-consumer option for tools

[ https://issues.apache.org/jira/browse/KAFKA-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495006#comment-16495006 ] Paolo Patierno commented on KAFKA-5588: --- [~ijuma] I have just provided a PR for this one for

[jira] [Commented] (KAFKA-5588) Remove deprecated new-consumer option for tools

[ https://issues.apache.org/jira/browse/KAFKA-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494989#comment-16494989 ] ASF GitHub Bot commented on KAFKA-5588: --- ppatierno opened a new pull request #5097: KAFKA-5588:

[jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494982#comment-16494982 ] Di Campo commented on KAFKA-6188: - Hi , I faced same issue as [~chubao] when deleting a KafkaStreams

[jira] [Created] (KAFKA-6968) Call RebalanceListener in MockConsumer

Andras Beni created KAFKA-6968: -- Summary: Call RebalanceListener in MockConsumer Key: KAFKA-6968 URL: https://issues.apache.org/jira/browse/KAFKA-6968 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494742#comment-16494742 ] Jagadesh Adireddi commented on KAFKA-6906: -- [~guozhang], Thank you for the conformation. Will 

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494731#comment-16494731 ] Don commented on KAFKA-3042: We still observed "Cached zkVersion 54 not equal to that in zookeeper, skip

[jira] [Commented] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16494725#comment-16494725 ] Guozhang Wang commented on KAFKA-6906: -- [~mjsax] Sounds good to me. For this JIRA just doing 1/2/3