[jira] [Commented] (KAFKA-2842) BrokerEndPoint regex does't support hostname with _

[ https://issues.apache.org/jira/browse/KAFKA-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15021537#comment-15021537 ] Sachin Pasalkar commented on KAFKA-2842: I just saw the console-consumer & simpleC

[jira] [Updated] (KAFKA-1818) Code cleanup in ReplicationUtils including unit test

[ https://issues.apache.org/jira/browse/KAFKA-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1818: - Assignee: Eric Olander (was: Neha Narkhede) > Code cleanup in ReplicationUtils including unit tes

[jira] [Updated] (KAFKA-1836) metadata.fetch.timeout.ms set to zero blocks forever

[ https://issues.apache.org/jira/browse/KAFKA-1836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1836: - Assignee: jaikiran pai > metadata.fetch.timeout.ms set to zero blocks forever > --

[jira] [Updated] (KAFKA-1947) can't explicitly set replica-assignment when add partitions

[ https://issues.apache.org/jira/browse/KAFKA-1947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1947: - Assignee: Honghai Chen > can't explicitly set replica-assignment when add partitions > ---

[jira] [Updated] (KAFKA-1957) code doc typo

[ https://issues.apache.org/jira/browse/KAFKA-1957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1957: - Assignee: Yaguo Zhou > code doc typo > - > > Key: KAFKA-1957 >

[jira] [Updated] (KAFKA-2592) Stop Writing the Change-log in store.put() / delete() for Non-transactional Store

[ https://issues.apache.org/jira/browse/KAFKA-2592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2592: - Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Stop Writing the Change-log in stor

[jira] [Updated] (KAFKA-2593) KeyValueStores should not require use of the context's default serializers and deserializers

[ https://issues.apache.org/jira/browse/KAFKA-2593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2593: - Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > KeyValueStores should not require u

[jira] [Updated] (KAFKA-2594) Add a key-value store that is a fixed-capacity in-memory LRU cache

[ https://issues.apache.org/jira/browse/KAFKA-2594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2594: - Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Add a key-value store that is a fix

[jira] [Updated] (KAFKA-2591) Remove Persistent Data before Restoringafter a Fault

[ https://issues.apache.org/jira/browse/KAFKA-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2591: - Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Remove Persistent Data before Resto

[jira] [Updated] (KAFKA-2600) Make KStream interfaces compatible with Java 8 java.util.function

[ https://issues.apache.org/jira/browse/KAFKA-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2600: - Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Make KStream interfaces compatible

[jira] [Updated] (KAFKA-2624) Truncate warn message logged after truncating partitions

[ https://issues.apache.org/jira/browse/KAFKA-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2624: - Assignee: Francois Visconte (was: Neha Narkhede) > Truncate warn message logged after truncating

[jira] [Updated] (KAFKA-2652) Incorporate the new consumer protocol with partition-group interface

[ https://issues.apache.org/jira/browse/KAFKA-2652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2652: - Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Incorporate the new consumer protoc

[jira] [Updated] (KAFKA-2654) Avoid calling Consumer.poll(0) in each iteration

[ https://issues.apache.org/jira/browse/KAFKA-2654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2654: - Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Avoid calling Consumer.poll(0) in e

[jira] [Updated] (KAFKA-2707) Make KStream processor names deterministic

[ https://issues.apache.org/jira/browse/KAFKA-2707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2707: - Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Make KStream processor names determ

[jira] [Updated] (KAFKA-2706) Make state stores first class citizens in the processor DAG

[ https://issues.apache.org/jira/browse/KAFKA-2706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2706: - Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Make state stores first class citiz

[jira] [Updated] (KAFKA-2694) Make a task id be a composite id of a topic group id and a partition id

[ https://issues.apache.org/jira/browse/KAFKA-2694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2694: - Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > Make a task id be a composite id of

[jira] [Updated] (KAFKA-2727) initialize only the part of the topology relevant to the task

[ https://issues.apache.org/jira/browse/KAFKA-2727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2727: - Fix Version/s: (was: 0.9.0.0) 0.9.1.0 > initialize only the part of the top

[jira] [Updated] (KAFKA-2873) o.a.k.connect.util.KafkaBasedLogTest failure in 0.9 RC4

[ https://issues.apache.org/jira/browse/KAFKA-2873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2873: Issue Type: Sub-task (was: Bug) Parent: KAFKA-2054 > o.a.k.connect.util.KafkaBasedLogTest f

[jira] [Updated] (KAFKA-2873) o.a.k.connect.util.KafkaBasedLogTest failure in 0.9 RC4

[ https://issues.apache.org/jira/browse/KAFKA-2873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2873: Summary: o.a.k.connect.util.KafkaBasedLogTest failure in 0.9 RC4 (was: 0.9 RC4 test failure in )

[jira] [Updated] (KAFKA-2873) 0.9 RC4 test failure in

[ https://issues.apache.org/jira/browse/KAFKA-2873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2873: Summary: 0.9 RC4 test failure in (was: 0.9 RC4 test failure) > 0.9 RC4 test failure in >

[jira] [Created] (KAFKA-2873) 0.9 RC4 test failure

Jiangjie Qin created KAFKA-2873: --- Summary: 0.9 RC4 test failure Key: KAFKA-2873 URL: https://issues.apache.org/jira/browse/KAFKA-2873 Project: Kafka Issue Type: Bug Reporter: Jiangj