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

2023-01-04 Thread Stephane Maarek (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-14573: Description: Create a topic with 6 partitions (that's how the behavior is observed) ```

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

2023-01-04 Thread Stephane Maarek (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-14573: Description: Create a topic with 6 partitions (that's how the behavior is observed) ```

[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] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

2018-11-15 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688044#comment-16688044 ] Stephane Maarek commented on KAFKA-1194: [~Kobi Hikri] excellent, I'll be happy to help out and

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

2018-09-12 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16612019#comment-16612019 ] Stephane Maarek commented on KAFKA-1194: Thanks [~Kobi Hikri]! That's what I thought, it was a

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

2018-09-05 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604408#comment-16604408 ] Stephane Maarek commented on KAFKA-1194: hi [~Kobi Hikri], can you please test one more time

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

2018-09-02 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16601613#comment-16601613 ] Stephane Maarek commented on KAFKA-1194: [~lindong] Not fixed as of {code} [2018-09-02

[jira] [Commented] (KAFKA-7278) replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

2018-09-02 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16601552#comment-16601552 ] Stephane Maarek commented on KAFKA-7278: [~lindong] Unfortunately, this does not fix

[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] [Commented] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

2018-07-01 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16529262#comment-16529262 ] Stephane Maarek commented on KAFKA-7077: Related but not the same. KAFKA-6340 requires some

[jira] [Updated] (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)
[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-7077: --- Description: KIP Link:

[jira] [Updated] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

2018-06-20 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-7077: --- Summary: KIP-318: Make Kafka Connect Source idempotent (was:

[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] [Commented] (KAFKA-7066) Make Streams Runtime Error User Friendly in Case of Serialisation exception

2018-06-16 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514953#comment-16514953 ] Stephane Maarek commented on KAFKA-7066: Thanks [~mjsax] . I think that helps, but my PR looks

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

2018-06-16 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek reassigned KAFKA-7066: -- Assignee: Stephane Maarek > Make Streams Runtime Error User Friendly in Case of

[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] [Commented] (KAFKA-6323) punctuate with WALL_CLOCK_TIME triggered immediately

2017-12-08 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284366#comment-16284366 ] Stephane Maarek commented on KAFKA-6323: Fully agree [~guozhang] . I fully agree on the punctuate

[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] [Commented] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199387#comment-16199387 ] Stephane Maarek commented on KAFKA-6007: I agree. You are correct in your assessment. Overall this

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

2017-10-03 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephane Maarek updated KAFKA-5993: --- Summary: Kafka Admin Client throws a warning for sasl.jaas.config (was: Kafka AdminClient

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

2017-10-03 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16190808#comment-16190808 ] Stephane Maarek edited comment on KAFKA-5993 at 10/4/17 4:52 AM: - [~ijuma]

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

2017-10-03 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16190808#comment-16190808 ] Stephane Maarek commented on KAFKA-5993: [~ijuma] Indeed it does support security settings. The

[jira] [Created] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-03 Thread Stephane Maarek (JIRA)
Stephane Maarek created KAFKA-6007: -- Summary: Connect can't validate against transforms in plugins.path Key: KAFKA-6007 URL: https://issues.apache.org/jira/browse/KAFKA-6007 Project: Kafka

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

2017-09-29 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185455#comment-16185455 ] Stephane Maarek commented on KAFKA-5993: Okay thanks indeed that's odd. Let me confirm. Thanks

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

2017-09-29 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185445#comment-16185445 ] Stephane Maarek commented on KAFKA-5993: I'm not on my laptop but I had created an admin client

[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