[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=16094629#comment-16094629 ] Joe Wood commented on KAFKA-5243: - I'll raise a KIP for this as it's become essential for distributed

[jira] [Updated] (KAFKA-5615) Consumer hang in poll method while rebalancing is in progress (Duplicate)

[ https://issues.apache.org/jira/browse/KAFKA-5615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Geoffrey Stewart updated KAFKA-5615: Description: Opening this issue to bring some attention to another Jira which may need to

[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

[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

[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] [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=16094541#comment-16094541 ] ASF GitHub Bot commented on KAFKA-5608: --- GitHub user ijuma opened a pull request:

[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] [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:

[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=16094568#comment-16094568 ] Matthias J. Sax commented on KAFKA-4750: As mentioned above. I would go with option (1) as null

[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=16094430#comment-16094430 ] huxihx commented on KAFKA-5592: --- Is it a duplicate of

[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=16094572#comment-16094572 ] ASF GitHub Bot commented on KAFKA-5134: --- Github user asfgit closed the pull request at:

[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=16094953#comment-16094953 ] ASF GitHub Bot commented on KAFKA-5620: --- GitHub user jcustenborder opened a pull 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=16094920#comment-16094920 ] Yogesh BG edited comment on KAFKA-5618 at 7/20/17 4:29 PM: --- You can see it

[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:

[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=16094910#comment-16094910 ] Yogesh BG commented on KAFKA-5618: -- It hung up... initially had those exception but after that i restart

[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=16095565#comment-16095565 ] Guozhang Wang commented on KAFKA-4559: -- Thanks Ravi, I can assign you to this ticket. Also cc'ing

[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

[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

[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

[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=16095721#comment-16095721 ] james chien edited comment on KAFKA-5606 at 7/21/17 3:35 AM: - So the goal is

[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=16095776#comment-16095776 ] Matthias J. Sax commented on KAFKA-4750: I understand what you are saying, but encoding an empty

[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=16095781#comment-16095781 ] ASF GitHub Bot commented on KAFKA-5468: --- Github user asfgit closed the pull request at:

[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=16078812#comment-16078812 ] Vahid Hashemian edited comment on KAFKA-3356 at 7/20/17 10:25 PM: --

[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

[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

[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

[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

[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=16095693#comment-16095693 ] ASF GitHub Bot commented on KAFKA-5623: --- Github user asfgit closed the pull request at:

[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=16095701#comment-16095701 ] ASF GitHub Bot commented on KAFKA-5410: --- Github user asfgit closed the pull request at:

[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

[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

[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=16095737#comment-16095737 ] ASF GitHub Bot commented on KAFKA-5535: --- GitHub user ewencp opened a pull request:

[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=16095769#comment-16095769 ] Matthias J. Sax commented on KAFKA-4468: [~guozhang] We have to distinguish two cases: (1)

[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

[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

[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

[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

[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

[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=16095747#comment-16095747 ] Ewen Cheslack-Postava commented on KAFKA-5505: -- There's been some discussion about more

[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-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=16095627#comment-16095627 ] zhu fangbo commented on KAFKA-5616: --- [~ijuma] I have read this document many times, the instruction of

[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

[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

[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

[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

[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

[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=16095775#comment-16095775 ] ASF GitHub Bot commented on KAFKA-5431: --- Github user asfgit closed the pull request at:

[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=16095784#comment-16095784 ] Matthias J. Sax commented on KAFKA-5618: Thanks for following up. If it hangs and the threads

[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=16095722#comment-16095722 ] Ewen Cheslack-Postava commented on KAFKA-5563: -- [~sliebau] I think validation that they match

[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=16095721#comment-16095721 ] james chien commented on KAFKA-5606: So the goal is replacing {code:java} RequestFuture.succeeded()

[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] [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

[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

[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

[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

[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-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=16095792#comment-16095792 ] Ewen Cheslack-Postava commented on KAFKA-4827: -- [~sliebau] Yeah, naming is, unfortunately,

[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=16095793#comment-16095793 ] Guozhang Wang commented on KAFKA-4468: -- Even in PAPI, I think today we do not expose APIs for users

[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=16095282#comment-16095282 ] ASF GitHub Bot commented on KAFKA-5610: --- Github user asfgit closed the pull request at:

[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