[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094308#comment-16094308 ] Damian Guy commented on KAFKA-4750: --- I'd go with the first option as i believe that was

[jira] [Commented] (KAFKA-5592) Connection with plain client to SSL-secured broker causes OOM

[ https://issues.apache.org/jira/browse/KAFKA-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094430#comment-16094430 ] huxihx commented on KAFKA-5592: --- Is it a duplicate of [KAFKA-4090|https://issues.apache.org

[jira] [Created] (KAFKA-5616) can not perform a rolling upgrade from a non-secure to a secure Kafka cluster

zhu fangbo created KAFKA-5616: - Summary: can not perform a rolling upgrade from a non-secure to a secure Kafka cluster Key: KAFKA-5616 URL: https://issues.apache.org/jira/browse/KAFKA-5616 Project: Kafka

[jira] [Updated] (KAFKA-5616) can not perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Comment Edited] (KAFKA-5592) Connection with plain client to SSL-secured broker causes OOM

[ https://issues.apache.org/jira/browse/KAFKA-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094430#comment-16094430 ] huxihx edited comment on KAFKA-5592 at 7/20/17 10:13 AM: - Is it a

[jira] [Created] (KAFKA-5617) Update to the list of third-party clients

Daniel Schierbeck created KAFKA-5617: Summary: Update to the list of third-party clients Key: KAFKA-5617 URL: https://issues.apache.org/jira/browse/KAFKA-5617 Project: Kafka Issue Type: W

[jira] [Commented] (KAFKA-5608) System test failure due to timeout starting Jmx tool

[ https://issues.apache.org/jira/browse/KAFKA-5608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094541#comment-16094541 ] ASF GitHub Bot commented on KAFKA-5608: --- GitHub user ijuma opened a pull request:

[jira] [Created] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info

Yogesh BG created KAFKA-5618: Summary: Kafka stream not receive any topic/partitions/records info Key: KAFKA-5618 URL: https://issues.apache.org/jira/browse/KAFKA-5618 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Summary: unable perform a rolling upgrade from a non-secure to a secure Kafka cluster (was: can not per

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094568#comment-16094568 ] Matthias J. Sax commented on KAFKA-4750: As mentioned above. I would go with optio

[jira] [Commented] (KAFKA-5134) Replace zkClient.getChildren method with zkUtils.getChildren

[ https://issues.apache.org/jira/browse/KAFKA-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094572#comment-16094572 ] ASF GitHub Bot commented on KAFKA-5134: --- Github user asfgit closed the pull request

[jira] [Created] (KAFKA-5619) Make --new-consumer option as deprecated in all tools

Paolo Patierno created KAFKA-5619: - Summary: Make --new-consumer option as deprecated in all tools Key: KAFKA-5619 URL: https://issues.apache.org/jira/browse/KAFKA-5619 Project: Kafka Issue T

[jira] [Commented] (KAFKA-5243) Request to add row limit in ReadOnlyKeyValueStore range function

[ https://issues.apache.org/jira/browse/KAFKA-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094629#comment-16094629 ] Joe Wood commented on KAFKA-5243: - I'll raise a KIP for this as it's become essential for

[jira] [Updated] (KAFKA-5619) Make --new-consumer option as deprecated in all tools

[ https://issues.apache.org/jira/browse/KAFKA-5619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5619: -- Description: Hi, as already described by the [KAFKA-5599|https://issues.apache.org/jira/browse/

[jira] [Commented] (KAFKA-5123) Refactor ZkUtils readData* methods

[ https://issues.apache.org/jira/browse/KAFKA-5123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094675#comment-16094675 ] ASF GitHub Bot commented on KAFKA-5123: --- GitHub user baluchicken opened a pull reque

[jira] [Commented] (KAFKA-5619) Make --new-consumer option as deprecated in all tools

[ https://issues.apache.org/jira/browse/KAFKA-5619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094699#comment-16094699 ] ASF GitHub Bot commented on KAFKA-5619: --- GitHub user ppatierno opened a pull request

[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094716#comment-16094716 ] ASF GitHub Bot commented on KAFKA-4830: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5341) Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics

[ https://issues.apache.org/jira/browse/KAFKA-5341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094730#comment-16094730 ] Alex Lamaison commented on KAFKA-5341: -- This would be a really useful metric to have.

[jira] [Commented] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094875#comment-16094875 ] Ismael Juma commented on KAFKA-5616: Did you follow these instructions? http://docs.c

[jira] [Commented] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info

[ https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094886#comment-16094886 ] Matthias J. Sax commented on KAFKA-5618: [~yogeshbelur] I did have a look into the

[jira] [Commented] (KAFKA-5556) KafkaConsumer.commitSync throws IllegalStateException: Attempt to retrieve exception from future which hasn't failed

[ https://issues.apache.org/jira/browse/KAFKA-5556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094895#comment-16094895 ] ASF GitHub Bot commented on KAFKA-5556: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info

[ https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094910#comment-16094910 ] Yogesh BG commented on KAFKA-5618: -- It hung up... initially had those exception but after

[jira] [Commented] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info

[ https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094920#comment-16094920 ] Yogesh BG commented on KAFKA-5618: -- You can see it periodically sending metadata request

[jira] [Comment Edited] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info

[ https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094920#comment-16094920 ] Yogesh BG edited comment on KAFKA-5618 at 7/20/17 4:29 PM: --- You

[jira] [Commented] (KAFKA-5561) Rewrite TopicCommand using the new Admin client

[ https://issues.apache.org/jira/browse/KAFKA-5561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094938#comment-16094938 ] Paolo Patierno commented on KAFKA-5561: --- [~ijuma] I see that the altering topic conf

[jira] [Created] (KAFKA-5620) SerializationException in doSend() masks class cast exception

Jeremy Custenborder created KAFKA-5620: -- Summary: SerializationException in doSend() masks class cast exception Key: KAFKA-5620 URL: https://issues.apache.org/jira/browse/KAFKA-5620 Project: Kafk

[jira] [Commented] (KAFKA-5620) SerializationException in doSend() masks class cast exception

[ https://issues.apache.org/jira/browse/KAFKA-5620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16094953#comment-16094953 ] ASF GitHub Bot commented on KAFKA-5620: --- GitHub user jcustenborder opened a pull req

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095052#comment-16095052 ] Guozhang Wang commented on KAFKA-4750: -- I think technically I'm convinced that option

[jira] [Commented] (KAFKA-3856) Cleanup Kafka Streams builder API

[ https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095068#comment-16095068 ] ASF GitHub Bot commented on KAFKA-3856: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095174#comment-16095174 ] Apurva Mehta commented on KAFKA-5621: - cc [~hachikuji] > The producer should retry ex

[jira] [Created] (KAFKA-5621) The producer should retry expired batches when retries are enabled

Apurva Mehta created KAFKA-5621: --- Summary: The producer should retry expired batches when retries are enabled Key: KAFKA-5621 URL: https://issues.apache.org/jira/browse/KAFKA-5621 Project: Kafka

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095190#comment-16095190 ] Ismael Juma commented on KAFKA-5621: We definitely need to do something about this. An

[jira] [Commented] (KAFKA-5610) KafkaApis.handleWriteTxnMarkerRequest can return UNSUPPORTED_FOR_MESSAGE_FORMAT error on partition emigration

[ https://issues.apache.org/jira/browse/KAFKA-5610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095282#comment-16095282 ] ASF GitHub Bot commented on KAFKA-5610: --- Github user asfgit closed the pull request

[jira] [Created] (KAFKA-5622) Add support for JMXMP

Vijay Prakash created KAFKA-5622: Summary: Add support for JMXMP Key: KAFKA-5622 URL: https://issues.apache.org/jira/browse/KAFKA-5622 Project: Kafka Issue Type: New Feature Repor

[jira] [Comment Edited] (KAFKA-3356) Remove ConsumerOffsetChecker, deprecated in 0.9, in 0.11

[ https://issues.apache.org/jira/browse/KAFKA-3356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16078812#comment-16078812 ] Vahid Hashemian edited comment on KAFKA-3356 at 7/20/17 10:25 PM: --

[jira] [Commented] (KAFKA-5611) One or more consumers in a consumer-group stop consuming after rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095510#comment-16095510 ] Panos Skianis commented on KAFKA-5611: -- huxihx, in general not really. Looking at som

[jira] [Commented] (KAFKA-4559) Add a site search bar on the Web site

[ https://issues.apache.org/jira/browse/KAFKA-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095538#comment-16095538 ] Ravi Raj Singh commented on KAFKA-4559: --- I can implement this functionality. Please

[jira] [Comment Edited] (KAFKA-4559) Add a site search bar on the Web site

[ https://issues.apache.org/jira/browse/KAFKA-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095538#comment-16095538 ] Ravi Raj Singh edited comment on KAFKA-4559 at 7/20/17 11:17 PM: ---

[jira] [Commented] (KAFKA-4559) Add a site search bar on the Web site

[ https://issues.apache.org/jira/browse/KAFKA-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095565#comment-16095565 ] Guozhang Wang commented on KAFKA-4559: -- Thanks Ravi, I can assign you to this ticket.

[jira] [Assigned] (KAFKA-4559) Add a site search bar on the Web site

[ https://issues.apache.org/jira/browse/KAFKA-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4559: Assignee: Ravi Raj Singh > Add a site search bar on the Web site >

[jira] [Created] (KAFKA-5623) ducktape kafka service: do not assume Service contains num_nodes

Colin P. McCabe created KAFKA-5623: -- Summary: ducktape kafka service: do not assume Service contains num_nodes Key: KAFKA-5623 URL: https://issues.apache.org/jira/browse/KAFKA-5623 Project: Kafka

[jira] [Commented] (KAFKA-5623) ducktape kafka service: do not assume Service contains num_nodes

[ https://issues.apache.org/jira/browse/KAFKA-5623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095588#comment-16095588 ] ASF GitHub Bot commented on KAFKA-5623: --- GitHub user cmccabe opened a pull request:

[jira] [Commented] (KAFKA-5534) KafkaConsumer offsetsForTimes should include partitions in result even if no offset could be found

[ https://issues.apache.org/jira/browse/KAFKA-5534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095604#comment-16095604 ] ASF GitHub Bot commented on KAFKA-5534: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095627#comment-16095627 ] zhu fangbo commented on KAFKA-5616: --- [~ijuma] I have read this document many times, the

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Updated] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5616: -- Description: I want to upgrade my unsecure kafka cluster to a secure one whitch support SASL_PLAINT pro

[jira] [Resolved] (KAFKA-5623) ducktape kafka service: do not assume Service contains num_nodes

[ https://issues.apache.org/jira/browse/KAFKA-5623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5623. -- Resolution: Fixed Fix Version/s: 0.11.0.1 0.10.2.2

[jira] [Commented] (KAFKA-5623) ducktape kafka service: do not assume Service contains num_nodes

[ https://issues.apache.org/jira/browse/KAFKA-5623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095693#comment-16095693 ] ASF GitHub Bot commented on KAFKA-5623: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5410) Fix taskClass() method name in Connector and flush() signature in SinkTask

[ https://issues.apache.org/jira/browse/KAFKA-5410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095701#comment-16095701 ] ASF GitHub Bot commented on KAFKA-5410: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5606) Review consumer's RequestFuture usage pattern

[ https://issues.apache.org/jira/browse/KAFKA-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095715#comment-16095715 ] james chien commented on KAFKA-5606: I am interest with this :D > Review consumer's R

[jira] [Commented] (KAFKA-5606) Review consumer's RequestFuture usage pattern

[ https://issues.apache.org/jira/browse/KAFKA-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095721#comment-16095721 ] james chien commented on KAFKA-5606: So the goal is replacing {code:java} RequestFutu

[jira] [Commented] (KAFKA-5563) Clarify handling of connector name in config

[ https://issues.apache.org/jira/browse/KAFKA-5563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095722#comment-16095722 ] Ewen Cheslack-Postava commented on KAFKA-5563: -- [~sliebau] I think validation

[jira] [Assigned] (KAFKA-5606) Review consumer's RequestFuture usage pattern

[ https://issues.apache.org/jira/browse/KAFKA-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien reassigned KAFKA-5606: -- Assignee: james chien > Review consumer's RequestFuture usage pattern > ---

[jira] [Comment Edited] (KAFKA-5606) Review consumer's RequestFuture usage pattern

[ https://issues.apache.org/jira/browse/KAFKA-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095721#comment-16095721 ] james chien edited comment on KAFKA-5606 at 7/21/17 3:35 AM: -

[jira] [Commented] (KAFKA-4559) Add a site search bar on the Web site

[ https://issues.apache.org/jira/browse/KAFKA-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095728#comment-16095728 ] Ravi Raj Singh commented on KAFKA-4559: --- Had a quick overview of the repo, based on

[jira] [Assigned] (KAFKA-5535) Transformations - tranformations for value broken on tombstone events

[ https://issues.apache.org/jira/browse/KAFKA-5535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-5535: Assignee: Ewen Cheslack-Postava > Transformations - tranformations for valu

[jira] [Commented] (KAFKA-5535) Transformations - tranformations for value broken on tombstone events

[ https://issues.apache.org/jira/browse/KAFKA-5535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095737#comment-16095737 ] ASF GitHub Bot commented on KAFKA-5535: --- GitHub user ewencp opened a pull request:

[jira] [Commented] (KAFKA-5505) Connect: Do not restart connector and existing tasks on task-set change

[ https://issues.apache.org/jira/browse/KAFKA-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095747#comment-16095747 ] Ewen Cheslack-Postava commented on KAFKA-5505: -- There's been some discussion

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095769#comment-16095769 ] Matthias J. Sax commented on KAFKA-4468: [~guozhang] We have to distinguish two ca

[jira] [Assigned] (KAFKA-5468) Change Source offset commit message to info to match Sink behaviour

[ https://issues.apache.org/jira/browse/KAFKA-5468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-5468: Assignee: Stephane Maarek Reviewer: Ewen Cheslack-Postava > Change Sour

[jira] [Commented] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095773#comment-16095773 ] Matthias J. Sax commented on KAFKA-5070: Thanks for looping back [~kchen]! Just t

[jira] [Resolved] (KAFKA-5431) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

[ https://issues.apache.org/jira/browse/KAFKA-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-5431. Resolution: Fixed Fix Version/s: 0.11.1.0 Issue resolved by pull request 3525 [https://github.com/apa

[jira] [Commented] (KAFKA-5431) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

[ https://issues.apache.org/jira/browse/KAFKA-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095775#comment-16095775 ] ASF GitHub Bot commented on KAFKA-5431: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095776#comment-16095776 ] Matthias J. Sax commented on KAFKA-4750: I understand what you are saying, but enc

[jira] [Commented] (KAFKA-5468) Change Source offset commit message to info to match Sink behaviour

[ https://issues.apache.org/jira/browse/KAFKA-5468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095781#comment-16095781 ] ASF GitHub Bot commented on KAFKA-5468: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5618) Kafka stream not receive any topic/partitions/records info

[ https://issues.apache.org/jira/browse/KAFKA-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095784#comment-16095784 ] Matthias J. Sax commented on KAFKA-5618: Thanks for following up. If it hangs and

[jira] [Commented] (KAFKA-4827) Kafka connect: error with special characters in connector name

[ https://issues.apache.org/jira/browse/KAFKA-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095792#comment-16095792 ] Ewen Cheslack-Postava commented on KAFKA-4827: -- [~sliebau] Yeah, naming is, u

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095793#comment-16095793 ] Guozhang Wang commented on KAFKA-4468: -- Even in PAPI, I think today we do not expose

[jira] [Resolved] (KAFKA-5582) Log compaction with preallocation enabled does not trim segments

[ https://issues.apache.org/jira/browse/KAFKA-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-5582. --- Resolution: Duplicate > Log compaction with preallocation enabled does not trim segments > ---

[jira] [Commented] (KAFKA-4915) Make logging consistent

[ https://issues.apache.org/jira/browse/KAFKA-4915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095825#comment-16095825 ] Ewen Cheslack-Postava commented on KAFKA-4915: -- [~dernasherbrezon] Can you cl

[jira] [Commented] (KAFKA-5000) Framework should log some progress information regularly to assist in troubleshooting

[ https://issues.apache.org/jira/browse/KAFKA-5000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095830#comment-16095830 ] Ewen Cheslack-Postava commented on KAFKA-5000: -- Should this be logs or just c

[jira] [Assigned] (KAFKA-4930) Connect Rest API allows creating connectors with an empty name

[ https://issues.apache.org/jira/browse/KAFKA-4930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-4930: Assignee: Sönke Liebau > Connect Rest API allows creating connectors with a

  1   2   >