[jira] [Updated] (KAFKA-4942) Kafka Connect: Offset committing times out before expected

2017-03-22 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-4942: --- Description: On Kafka 0.10.2.0 I run a connector that deals with a lot of data, in a kafka

[jira] [Updated] (KAFKA-4942) Kafka Connect: Offset committing times out before expected

2017-03-22 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-4942: --- Description: On Kafka 0.10.2.0 I run a connector that deals with a lot of data, in a kafka

[jira] [Created] (KAFKA-4942) Kafka Connect: Offset committing times out before expected

2017-03-22 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-4942: -- Summary: Kafka Connect: Offset committing times out before expected Key: KAFKA-4942 URL: https://issues.apache.org/jira/browse/KAFKA-4942 Project: Kafka

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

2017-03-22 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15937468#comment-15937468 ] Stephane Maarek commented on KAFKA-2729: If I may add, this is a pretty bad issue, but it got

[jira] [Updated] (KAFKA-4871) Kafka doesn't respect TTL on Zookeeper hostname - crash if zookeeper IP changes

2017-03-09 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-4871: --- Yeah definitely ! Seeing how this issue has been opened for two years I'm quite worried about

[jira] [Created] (KAFKA-4871) Kafka doesn't respect TTL on Zookeeper hostname - crash if zookeeper IP changes

2017-03-08 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-4871: -- Summary: Kafka doesn't respect TTL on Zookeeper hostname - crash if zookeeper IP changes Key: KAFKA-4871 URL: https://issues.apache.org/jira/browse/KAFKA-4871

[jira] [Updated] (KAFKA-4864) Kafka Secure Migrator tool doesn't secure all the nodes

2017-03-07 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-4864: --- Description: It seems that the secure nodes as referred by ZkUtils.scala are the following

[jira] [Updated] (KAFKA-4864) Kafka Secure Migrator tool doesn't secure all the nodes

2017-03-07 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-4864: --- Priority: Critical (was: Major) > Kafka Secure Migrator tool doesn't secure all the no

[jira] [Created] (KAFKA-4864) Kafka Secure Migrator tool doesn't secure all the nodes

2017-03-07 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-4864: -- Summary: Kafka Secure Migrator tool doesn't secure all the nodes Key: KAFKA-4864 URL: https://issues.apache.org/jira/browse/KAFKA-4864 Project: Kafka

Re: [ANNOUNCE] Apache Kafka 0.10.2.0 Released

2017-02-22 Thread Stephane Maarek
https://mvnrepository.com/artifact/org.apache.kafka/kafka_2.11 Am I missing something ? On 23 February 2017 at 9:21:08 am, Gwen Shapira (g...@confluent.io) wrote: I saw them in Maven yesterday? On Wed, Feb 22, 2017 at 2:15 PM, Stephane Maarek <steph...@simplemachines.com.au> wrote: >

Re: [ANNOUNCE] Apache Kafka 0.10.2.0 Released

2017-02-22 Thread Stephane Maarek
Awesome thanks a lot! When should we expect the dependencies to be released in Maven? (including 2.12 scala) On 23 February 2017 at 8:27:10 am, Jun Rao (j...@confluent.io) wrote: Thanks for driving the release, Ewen. Jun On Wed, Feb 22, 2017 at 12:33 AM, Ewen Cheslack-Postava

[jira] [Commented] (KAFKA-4782) change chroot for a kafka instance

2017-02-20 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15875133#comment-15875133 ] Stephane Maarek commented on KAFKA-4782: Use https://github.com/kshchepanovskyi/zkcopy > cha

[jira] [Created] (KAFKA-4781) Kafka should return its advertised host name before any protocol verification is done

2017-02-19 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-4781: -- Summary: Kafka should return its advertised host name before any protocol verification is done Key: KAFKA-4781 URL: https://issues.apache.org/jira/browse/KAFKA-4781

[jira] [Created] (KAFKA-4566) Can't Symlink to Kafka bins

2016-12-21 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-4566: -- Summary: Can't Symlink to Kafka bins Key: KAFKA-4566 URL: https://issues.apache.org/jira/browse/KAFKA-4566 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-4560) Min / Max Partitions Fetch Records params

2016-12-19 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15763036#comment-15763036 ] Stephane Maarek commented on KAFKA-4560: Basically if you set the max bytes, each partitions

[jira] [Commented] (KAFKA-4560) Min / Max Partitions Fetch Records params

2016-12-19 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15762979#comment-15762979 ] Stephane Maarek commented on KAFKA-4560: Hi [~huxi_2b], this setting has the following description

[jira] [Created] (KAFKA-4560) Min / Max Partitions Fetch Records params

2016-12-19 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-4560: -- Summary: Min / Max Partitions Fetch Records params Key: KAFKA-4560 URL: https://issues.apache.org/jira/browse/KAFKA-4560 Project: Kafka Issue Type

<    1   2