[jira] [Commented] (KAFKA-6982) java.lang.ArithmeticException: / by zero

[ https://issues.apache.org/jira/browse/KAFKA-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506806#comment-16506806 ] adam keyser commented on KAFKA-6982: Can this get added to 1.1.1 ? > java.lang.ArithmeticException:

[jira] [Created] (KAFKA-7028) super.users doesn't work with custom principals

Ismael Juma created KAFKA-7028: -- Summary: super.users doesn't work with custom principals Key: KAFKA-7028 URL: https://issues.apache.org/jira/browse/KAFKA-7028 Project: Kafka Issue Type: Bug

[jira] [Comment Edited] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506787#comment-16506787 ] radai rosenblatt edited comment on KAFKA-7012 at 6/9/18 2:06 AM: - no, not

[jira] [Comment Edited] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506787#comment-16506787 ] radai rosenblatt edited comment on KAFKA-7012 at 6/9/18 2:06 AM: - no, not

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506787#comment-16506787 ] radai rosenblatt commented on KAFKA-7012: - no, not all of poll(), just this part: {code}

[jira] [Assigned] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3955: -- Assignee: Dhruvil Shah (was: Ismael Juma) > Kafka log recovery doesn't truncate logs on

[jira] [Commented] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506721#comment-16506721 ] ASF GitHub Bot commented on KAFKA-6840: --- abbccdda closed pull request #5044: KAFKA-6840: windowed

[jira] [Updated] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-7026: --- Description: In the following scenario sticky assignor assigns a topic partition to two 

[jira] [Commented] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506722#comment-16506722 ] ASF GitHub Bot commented on KAFKA-6840: --- abbccdda opened a new pull request #5044: KAFKA-6840:

[jira] [Comment Edited] (KAFKA-4381) Add per partition lag metric to KafkaConsumer.

[ https://issues.apache.org/jira/browse/KAFKA-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506710#comment-16506710 ] Dong Lin edited comment on KAFKA-4381 at 6/8/18 11:51 PM: -- The metric added in

[jira] [Commented] (KAFKA-4381) Add per partition lag metric to KafkaConsumer.

[ https://issues.apache.org/jira/browse/KAFKA-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506710#comment-16506710 ] Dong Lin commented on KAFKA-4381: - The metric added in this patch includes topic partition in the metric

[jira] [Updated] (KAFKA-7027) Overloaded StreamsBuilder Build Method to Accept java.util.Properties

[ https://issues.apache.org/jira/browse/KAFKA-7027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7027: --- Labels: kip (was: needs-kip) > Overloaded StreamsBuilder Build Method to Accept

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506664#comment-16506664 ] rajadayalan perumalsamy commented on KAFKA-7012: do you mean to comment the poll method

[jira] [Updated] (KAFKA-7027) Overloaded StreamsBuilder Build Method to Accept java.util.Properties

[ https://issues.apache.org/jira/browse/KAFKA-7027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7027: --- Description: Add overloaded method to {{StreamsBuilder}} accepting a  {{java.utils.Properties}}

[jira] [Created] (KAFKA-7027) Overloaded StreamsBuilder Build Method to Accept java.util.Properties

Bill Bejeck created KAFKA-7027: -- Summary: Overloaded StreamsBuilder Build Method to Accept java.util.Properties Key: KAFKA-7027 URL: https://issues.apache.org/jira/browse/KAFKA-7027 Project: Kafka

[jira] [Commented] (KAFKA-6995) Make config "internal.leave.group.on.close" public

[ https://issues.apache.org/jira/browse/KAFKA-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506626#comment-16506626 ] Boyang Chen commented on KAFKA-6995: [~mjsax] That would be a viable solution. However, me as an end

[jira] [Created] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

Vahid Hashemian created KAFKA-7026: -- Summary: Sticky assignor could assign a partition to multiple consumers Key: KAFKA-7026 URL: https://issues.apache.org/jira/browse/KAFKA-7026 Project: Kafka

[jira] [Assigned] (KAFKA-7010) Rename ResourceNameType.ANY to MATCH

[ https://issues.apache.org/jira/browse/KAFKA-7010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Coates reassigned KAFKA-7010: -- Assignee: Andy Coates > Rename ResourceNameType.ANY to MATCH >

[jira] [Commented] (KAFKA-7022) Setting a very small segment.bytes can cause ReplicaFetcherThread to crash and in turn high number of under-replicated partitions

[ https://issues.apache.org/jira/browse/KAFKA-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506528#comment-16506528 ] ASF GitHub Bot commented on KAFKA-7022: --- rajinisivaram opened a new pull request #5167: KAFKA-7022:

[jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce

[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506333#comment-16506333 ] Matthias J. Sax commented on KAFKA-2260: Feature freeze for 2.0 release happened already. Thus,

[jira] [Resolved] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5697. -- Resolution: Fixed Fix Version/s: (was: 2.1.0) 2.0.0 >

[jira] [Commented] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506329#comment-16506329 ] ASF GitHub Bot commented on KAFKA-5697: --- guozhangwang closed pull request #5107: KAFKA-5697: Use

[jira] [Comment Edited] (KAFKA-7023) Kafka Streams RocksDB bulk loading config may not be honored with customized RocksDBConfigSetter

[ https://issues.apache.org/jira/browse/KAFKA-7023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506316#comment-16506316 ] Guozhang Wang edited comment on KAFKA-7023 at 6/8/18 5:43 PM: -- Thanks for

[jira] [Commented] (KAFKA-7023) Kafka Streams RocksDB bulk loading config may not be honored with customized RocksDBConfigSetter

[ https://issues.apache.org/jira/browse/KAFKA-7023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506316#comment-16506316 ] Guozhang Wang commented on KAFKA-7023: -- Thanks for the report! I think this is indeed a perf

[jira] [Commented] (KAFKA-6953) [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure)

[ https://issues.apache.org/jira/browse/KAFKA-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506311#comment-16506311 ] Matthias J. Sax commented on KAFKA-6953: Just looked it up. You did not share your wiki ID and

[jira] [Commented] (KAFKA-7023) Kafka Streams RocksDB bulk loading config may not be honored with customized RocksDBConfigSetter

[ https://issues.apache.org/jira/browse/KAFKA-7023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506290#comment-16506290 ] ASF GitHub Bot commented on KAFKA-7023: --- Ishiihara opened a new pull request #5166: KAFKA-7023:

[jira] [Updated] (KAFKA-7022) Setting a very small segment.bytes can cause ReplicaFetcherThread to crash and in turn an unhealthy cluster due to under-replicated partitions

[ https://issues.apache.org/jira/browse/KAFKA-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Koelli Mungee updated KAFKA-7022: - Summary: Setting a very small segment.bytes can cause ReplicaFetcherThread to crash and in turn

[jira] [Updated] (KAFKA-7022) Setting a very small segment.bytes can cause ReplicaFetcherThread to crash and in turn high number of under-replicated partitions

[ https://issues.apache.org/jira/browse/KAFKA-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Koelli Mungee updated KAFKA-7022: - Summary: Setting a very small segment.bytes can cause ReplicaFetcherThread to crash and in turn

[jira] [Updated] (KAFKA-7022) Setting a very small segment.bytes can cause ReplicaFetcher threads to crash and in turn an unhealthy cluster due to under-replicated partitions

[ https://issues.apache.org/jira/browse/KAFKA-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Koelli Mungee updated KAFKA-7022: - Description: The topic configuration segment.bytes was changed to 14 using the alter command.

[jira] [Resolved] (KAFKA-7006) Remove duplicate Scala ResourceNameType class

[ https://issues.apache.org/jira/browse/KAFKA-7006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-7006. Resolution: Fixed merged the PR to trunk and 2.0 branch. > Remove duplicate Scala ResourceNameType class

[jira] [Commented] (KAFKA-7006) Remove duplicate Scala ResourceNameType class

[ https://issues.apache.org/jira/browse/KAFKA-7006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506127#comment-16506127 ] ASF GitHub Bot commented on KAFKA-7006: --- junrao closed pull request #5152: KAFKA-7006 - remove

[jira] [Assigned] (KAFKA-7015) Enhance RecordCollectorImpl exceptions with more context information

[ https://issues.apache.org/jira/browse/KAFKA-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-7015: Assignee: Jagadesh Adireddi > Enhance RecordCollectorImpl exceptions with more

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

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506062#comment-16506062 ] Michael Hartle commented on KAFKA-1194: --- I can reproduce the crash on Windows with Apache Kafka

[jira] [Created] (KAFKA-7025) Android client support

Martin Vysny created KAFKA-7025: --- Summary: Android client support Key: KAFKA-7025 URL: https://issues.apache.org/jira/browse/KAFKA-7025 Project: Kafka Issue Type: Bug Components:

[jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506025#comment-16506025 ] Adam Bellemare commented on KAFKA-4628: --- Someone added me - thank you! I will be working on the KIP

[jira] [Created] (KAFKA-7024) Rocksdb state directory should be created before opening the DB

Abhishek Agarwal created KAFKA-7024: --- Summary: Rocksdb state directory should be created before opening the DB Key: KAFKA-7024 URL: https://issues.apache.org/jira/browse/KAFKA-7024 Project: Kafka

[jira] [Commented] (KAFKA-6946) Keep the session id for incremental fetch when fetch responses are throttled

[ https://issues.apache.org/jira/browse/KAFKA-6946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505975#comment-16505975 ] ASF GitHub Bot commented on KAFKA-6946: --- jonlee2 opened a new pull request #5164: KAFKA-6946: Keep

[jira] [Commented] (KAFKA-6291) Cannot close EmbeddedZookeeper on Windows

[ https://issues.apache.org/jira/browse/KAFKA-6291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505965#comment-16505965 ] Kamil Bar commented on KAFKA-6291: -- Any update on this issue? I'm also experiencing this problem on

[jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505943#comment-16505943 ] Adam Bellemare commented on KAFKA-4628: --- [~yuzhih...@gmail.com] - I am trying to start a KIP, but

[jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce

[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505891#comment-16505891 ] Sven Linstaedt commented on KAFKA-2260: --- Is there a chance for this proposal being scheduled with 

[jira] [Comment Edited] (KAFKA-2260) Allow specifying expected offset on produce

[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072735#comment-16072735 ] Sven Linstaedt edited comment on KAFKA-2260 at 6/8/18 9:44 AM: --- With

[jira] [Assigned] (KAFKA-7022) Setting a very small segment.bytes can cause ReplicaFetcher threads to crash and in turn an unhealthy cluster due to under-replicated partitions

[ https://issues.apache.org/jira/browse/KAFKA-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-7022: - Assignee: Rajini Sivaram > Setting a very small segment.bytes can cause ReplicaFetcher