[jira] [Created] (KAFKA-14573) RoundRobinPartitioner doesn't work as expected with topic that has 6 partitions

2023-01-04 Thread Stephane Maarek (Jira)
Stephane Maarek created KAFKA-14573: --- Summary: RoundRobinPartitioner doesn't work as expected with topic that has 6 partitions Key: KAFKA-14573 URL: https://issues.apache.org/jira/browse/KAFKA-14573

[jira] [Created] (KAFKA-7355) Topic Configuration Changes are not applied until reboot

2018-08-29 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-7355: -- Summary: Topic Configuration Changes are not applied until reboot Key: KAFKA-7355 URL: https://issues.apache.org/jira/browse/KAFKA-7355 Project: Kafka

[jira] [Created] (KAFKA-7077) producerProps.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "5") producerProps.put(ProducerConfig.ENABLE_IDEMPOTENCE, true)

2018-06-20 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-7077: -- Summary: producerProps.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "5") producerProps.put(ProducerConfig.ENABLE_IDEMPOTENCE, true) Key: KAFKA-7077 URL:

[jira] [Created] (KAFKA-7066) Make Streams Runtime Error User Friendly in Case of Serialisation exception

2018-06-16 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-7066: -- Summary: Make Streams Runtime Error User Friendly in Case of Serialisation exception Key: KAFKA-7066 URL: https://issues.apache.org/jira/browse/KAFKA-7066

[jira] [Created] (KAFKA-6092) Time passed in punctuate call is currentTime, not punctuate schedule time.

2017-10-19 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-6092: -- Summary: Time passed in punctuate call is currentTime, not punctuate schedule time. Key: KAFKA-6092 URL: https://issues.apache.org/jira/browse/KAFKA-6092

[jira] [Resolved] (KAFKA-5993) Kafka Admin Client throws a warning for sasl.jaas.config

2017-10-04 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek resolved KAFKA-5993. Resolution: Not A Problem > Kafka Admin Client throws a warning for sasl.jaas.config >

[jira] [Created] (KAFKA-5993) Kafka AdminClient does not support standard security settings

2017-09-28 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-5993: -- Summary: Kafka AdminClient does not support standard security settings Key: KAFKA-5993 URL: https://issues.apache.org/jira/browse/KAFKA-5993 Project: Kafka

[jira] [Created] (KAFKA-5992) Better Java Documentation for AdminClient Exceptions

2017-09-28 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-5992: -- Summary: Better Java Documentation for AdminClient Exceptions Key: KAFKA-5992 URL: https://issues.apache.org/jira/browse/KAFKA-5992 Project: Kafka Issue

[jira] [Created] (KAFKA-5851) CPU overhead to having partitions (even inactive)

2017-09-07 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-5851: -- Summary: CPU overhead to having partitions (even inactive) Key: KAFKA-5851 URL: https://issues.apache.org/jira/browse/KAFKA-5851 Project: Kafka Issue

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

2017-06-18 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-5468: -- Summary: Change Source offset commit message to info to match Sink behaviour Key: KAFKA-5468 URL: https://issues.apache.org/jira/browse/KAFKA-5468 Project: Kafka

[jira] [Commented] (KAFKA-5261) Performance improvement of SimpleAclAuthorizer

2017-05-17 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014945#comment-16014945 ] Stephane Maarek commented on KAFKA-5261: this and possibly {code} private def aclMatch(session:

[jira] [Updated] (KAFKA-5261) Performance improvement of SimpleAclAuthorizer

2017-05-17 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-5261: --- Summary: Performance improvement of SimpleAclAuthorizer (was: Performance improvement of

[jira] [Created] (KAFKA-5261) Performance improvement of SimpleAclAuthoriser

2017-05-17 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-5261: -- Summary: Performance improvement of SimpleAclAuthoriser Key: KAFKA-5261 URL: https://issues.apache.org/jira/browse/KAFKA-5261 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5092) KIP 141 - ProducerRecord Interface Improvements

2017-04-21 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-5092: --- Description: See KIP here:

[jira] [Updated] (KAFKA-5092) KIP 141 - ProducerRecord Interface Improvements

2017-04-21 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-5092: --- Summary: KIP 141 - ProducerRecord Interface Improvements (was: KIP 141 -

[jira] [Updated] (KAFKA-5092) KIP 141 - ProducerRecordBuilder Interface

2017-04-19 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-5092: --- Summary: KIP 141 - ProducerRecordBuilder Interface (was: KIP 141- ProducerRecordBuilder

[jira] [Updated] (KAFKA-5092) KIP 141- ProducerRecordBuilder Interface improvements

2017-04-19 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-5092: --- Summary: KIP 141- ProducerRecordBuilder Interface improvements (was: Producer record

[jira] [Created] (KAFKA-5092) Producer record interface

2017-04-19 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-5092: -- Summary: Producer record interface Key: KAFKA-5092 URL: https://issues.apache.org/jira/browse/KAFKA-5092 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-3436) Speed up controlled shutdown.

2017-03-28 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946392#comment-15946392 ] Stephane Maarek commented on KAFKA-3436: [~onurkaraman] I can't find the JIRA / PR regarding your

[jira] [Comment Edited] (KAFKA-3083) a soft failure in controller may leave a topic partition in an inconsistent state

2017-03-28 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946384#comment-15946384 ] Stephane Maarek edited comment on KAFKA-3083 at 3/29/17 1:42 AM: - Just hit

[jira] [Commented] (KAFKA-3083) a soft failure in controller may leave a topic partition in an inconsistent state

2017-03-28 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946384#comment-15946384 ] Stephane Maarek commented on KAFKA-3083: Just hit this issue in prod, and the only solution was to

[jira] [Commented] (KAFKA-4943) SCRAM secret's should be better protected with Zookeeper ACLs

2017-03-24 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15939916#comment-15939916 ] Stephane Maarek commented on KAFKA-4943: [~rsivaram] if Zookeeper has only cdrwa by the kafka

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

2017-03-23 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15939453#comment-15939453 ] Stephane Maarek edited comment on KAFKA-4942 at 3/23/17 11:57 PM: --

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

2017-03-23 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15939453#comment-15939453 ] Stephane Maarek commented on KAFKA-4942: [~ewencp] nothing weird from the log, except that EVERY

[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: --- Affects Version/s: 0.10.2.0 Priority: Major (was: Critical)

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

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

[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

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

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

[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

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