[jira] [Assigned] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Khaireddine Rezgui reassigned KAFKA-6399: - Assignee: (was: Khaireddine Rezgui) > Consider reducing

[jira] [Commented] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392493#comment-16392493 ] John Roesler commented on KAFKA-6399: - I'm not sure, since I haven't had a lot of time so far to build

[jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests

[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5943: -- Labels: connector (was: connector mock) > Reduce dependency on mock in connector tests >

[jira] [Commented] (KAFKA-5946) Give connector method parameter better name

[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392411#comment-16392411 ] Ted Yu commented on KAFKA-5946: --- Thanks for taking it. > Give connector method parameter better name >

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392410#comment-16392410 ] Ted Yu commented on KAFKA-6335: --- Sigh - the above link is no longer accessible. >

[jira] [Assigned] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-3978: --- Assignee: Dong Lin > Cannot truncate to a negative offset (-1) exception at broker startup >

[jira] [Commented] (KAFKA-6627) Console producer default config values override explicitly provided properties

[ https://issues.apache.org/jira/browse/KAFKA-6627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392272#comment-16392272 ] huxihx commented on KAFKA-6627: --- Seems this is similar to what's reported in

[jira] [Commented] (KAFKA-6539) KafkaConsumer endlessly try to connect to a dead broker, ignoring brokers alive

[ https://issues.apache.org/jira/browse/KAFKA-6539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392181#comment-16392181 ] Simon Trigona commented on KAFKA-6539: -- I don't currently have any technical details to add, but I

[jira] [Commented] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392105#comment-16392105 ] Guozhang Wang commented on KAFKA-6399: -- I'm +1 on changing this config's default from

[jira] [Created] (KAFKA-6631) Kafka Streams - Rebalancing exception in Kafka 1.0.0

Alexander Ivanichev created KAFKA-6631: -- Summary: Kafka Streams - Rebalancing exception in Kafka 1.0.0 Key: KAFKA-6631 URL: https://issues.apache.org/jira/browse/KAFKA-6631 Project: Kafka

[jira] [Commented] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392079#comment-16392079 ] Matthias J. Sax commented on KAFKA-6399: \cc [~vvcephei] [~bbejeck] [~guozhang] [~damianguy] What

[jira] [Commented] (KAFKA-6400) Consider setting default cache size to zero in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392078#comment-16392078 ] Matthias J. Sax commented on KAFKA-6400: Yes. CACHE_MAX_BYTES_BUFFERING_CONFIG refers to the

[jira] [Commented] (KAFKA-6630) Speed up the processing of TopicDeletionStopReplicaResponseReceived events on the controller

[ https://issues.apache.org/jira/browse/KAFKA-6630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392070#comment-16392070 ] ASF GitHub Bot commented on KAFKA-6630: --- gitlw opened a new pull request #4668: KAFKA-6630: Speed up

[jira] [Updated] (KAFKA-6630) Speed up the processing of TopicDeletionStopReplicaResponseReceived events on the controller

[ https://issues.apache.org/jira/browse/KAFKA-6630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang updated KAFKA-6630: -- Summary: Speed up the processing of TopicDeletionStopReplicaResponseReceived events on the controller

[jira] [Created] (KAFKA-6630) Speed up the processing of StopReplicaResponse events on the controller

Lucas Wang created KAFKA-6630: - Summary: Speed up the processing of StopReplicaResponse events on the controller Key: KAFKA-6630 URL: https://issues.apache.org/jira/browse/KAFKA-6630 Project: Kafka

[jira] [Created] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

Guozhang Wang created KAFKA-6629: Summary: SegmentedCacheFunctionTest does not cover session window serdes Key: KAFKA-6629 URL: https://issues.apache.org/jira/browse/KAFKA-6629 Project: Kafka

[jira] [Created] (KAFKA-6628) RocksDBSegmentedBytesStoreTest does not cover time window serdes

Guozhang Wang created KAFKA-6628: Summary: RocksDBSegmentedBytesStoreTest does not cover time window serdes Key: KAFKA-6628 URL: https://issues.apache.org/jira/browse/KAFKA-6628 Project: Kafka

[jira] [Commented] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

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

[jira] [Commented] (KAFKA-6612) Added logic to prevent increasing partition counts during topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-6612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391913#comment-16391913 ] ASF GitHub Bot commented on KAFKA-6612: --- gitlw opened a new pull request #4666: KAFKA-6612: Added

[jira] [Commented] (KAFKA-6612) Added logic to prevent increasing partition counts during topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-6612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391906#comment-16391906 ] ASF GitHub Bot commented on KAFKA-6612: --- gitlw closed pull request #4649: KAFKA-6612: Added logic to

[jira] [Commented] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391863#comment-16391863 ] Dong Lin commented on KAFKA-3978: - [~junrao] [~hachikuji] [~ijuma] I have a good theory now. I will submit

[jira] [Commented] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords

[ https://issues.apache.org/jira/browse/KAFKA-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391839#comment-16391839 ] Maciej Bryński commented on KAFKA-6626: --- I think even standard java HashMap can be used. The only

[jira] [Commented] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords

[ https://issues.apache.org/jira/browse/KAFKA-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391818#comment-16391818 ] Ted Yu commented on KAFKA-6626: --- There are alternatives in https://github.com/carrotsearch/hppc and

[jira] [Commented] (KAFKA-6473) Add MockProcessorContext to public test-utils

[ https://issues.apache.org/jira/browse/KAFKA-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391741#comment-16391741 ] John Roesler commented on KAFKA-6473: - I have created

[jira] [Commented] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391698#comment-16391698 ] Dong Lin commented on KAFKA-3978: - I also encountered this issue and I have been looking at this all day

[jira] [Updated] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords

[ https://issues.apache.org/jira/browse/KAFKA-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated KAFKA-6626: -- Description: Kafka Connect is using IdentityHashMap for storing records.

[jira] [Created] (KAFKA-6627) Console producer default config values override explicitly provided properties

Jason Gustafson created KAFKA-6627: -- Summary: Console producer default config values override explicitly provided properties Key: KAFKA-6627 URL: https://issues.apache.org/jira/browse/KAFKA-6627

[jira] [Commented] (KAFKA-6603) Kafka streams off heap memory usage does not match expected values from configuration

[ https://issues.apache.org/jira/browse/KAFKA-6603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391509#comment-16391509 ] Guozhang Wang commented on KAFKA-6603: -- Awesome, thanks for confirming Igor. At the mean time, we

[jira] [Commented] (KAFKA-6603) Kafka streams off heap memory usage does not match expected values from configuration

[ https://issues.apache.org/jira/browse/KAFKA-6603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391479#comment-16391479 ] Igor Calabria commented on KAFKA-6603: -- Yes, I was accessing the store directly and replacing the

[jira] [Commented] (KAFKA-6598) Kafka to support using ETCD beside Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391312#comment-16391312 ] Tom Bentley commented on KAFKA-6598: [~cmccabe] any more info about that (such as when might the KIP

[jira] [Commented] (KAFKA-3530) Making the broker-list option consistent across all tools

[ https://issues.apache.org/jira/browse/KAFKA-3530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391260#comment-16391260 ] Chia-Ping Tsai commented on KAFKA-3530: --- Any updates? Many peoples are confused by difference

[jira] [Commented] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

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

[jira] [Updated] (KAFKA-6625) kafka offset reset when I upgrade kafka from 0.11.0 to 1.0.0 version

[ https://issues.apache.org/jira/browse/KAFKA-6625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] barry010 updated KAFKA-6625: Description: when I upgrade kafka from 0.11.0 to 1.0.0 version，during I shut down the broker01 with kill

[jira] [Commented] (KAFKA-6195) DNS alias support for secured connections

[ https://issues.apache.org/jira/browse/KAFKA-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390947#comment-16390947 ] Rajini Sivaram commented on KAFKA-6195: --- In general, it is good to avoid configuration options if we

[jira] [Updated] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords

[ https://issues.apache.org/jira/browse/KAFKA-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated KAFKA-6626: -- Description: Kafka Connect is using IdentityHashMap for storing records.