[jira] [Commented] (KAFKA-7214) Mystic FATAL error

[ https://issues.apache.org/jira/browse/KAFKA-7214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742837#comment-16742837 ] Balaji commented on KAFKA-7214: --- Thanks [~guozhang]  .We  found issue invalid values were b

[jira] [Commented] (KAFKA-7497) Kafka Streams should support self-join on streams

[ https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742733#comment-16742733 ] Matthias J. Sax commented on KAFKA-7497: I disagree "that you have a stream of un

[jira] [Commented] (KAFKA-7815) SourceTask should expose ACK'd offsets, metadata

[ https://issues.apache.org/jira/browse/KAFKA-7815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742721#comment-16742721 ] Matthias J. Sax commented on KAFKA-7815: Thanks a lot :) > SourceTask should exp

[jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742726#comment-16742726 ] Matthias J. Sax commented on KAFKA-4850: Thanks a lot [~bharatviswa] – I closed y

[jira] [Commented] (KAFKA-7497) Kafka Streams should support self-join on streams

[ https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742729#comment-16742729 ] John Roesler commented on KAFKA-7497: - Note, the use-case reference above is now at:

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742728#comment-16742728 ] Matthias J. Sax commented on KAFKA-7149: There was not much progress recently. [~

[jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742725#comment-16742725 ] ASF GitHub Bot commented on KAFKA-4850: --- mjsax commented on pull request #3048: KAF

[jira] [Assigned] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4850: -- Assignee: Bill Bejeck (was: Bharat Viswanadham) > RocksDb cannot use Bloom Filters >

[jira] [Updated] (KAFKA-7821) Streams: default cache size can lose session windows in high-throughput deployment

[ https://issues.apache.org/jira/browse/KAFKA-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7821: --- Component/s: streams > Streams: default cache size can lose session windows in high-throughpu

[jira] [Updated] (KAFKA-7820) distinct count kafka streams api

[ https://issues.apache.org/jira/browse/KAFKA-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7820: --- Labels: needs-kip (was: ) > distinct count kafka streams api > -

[jira] [Updated] (KAFKA-7820) distinct count kafka streams api

[ https://issues.apache.org/jira/browse/KAFKA-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7820: --- Component/s: (was: core) streams > distinct count kafka streams api > --

[jira] [Commented] (KAFKA-7214) Mystic FATAL error

[ https://issues.apache.org/jira/browse/KAFKA-7214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742691#comment-16742691 ] Guozhang Wang commented on KAFKA-7214: -- [~balnpatil] I looked at your code and I thi

[jira] [Resolved] (KAFKA-6803) Caching is turned off for stream-stream Join

[ https://issues.apache.org/jira/browse/KAFKA-6803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6803. -- Resolution: Invalid > Caching is turned off for stream-stream Join > --

[jira] [Commented] (KAFKA-6803) Caching is turned off for stream-stream Join

[ https://issues.apache.org/jira/browse/KAFKA-6803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742659#comment-16742659 ] Guozhang Wang commented on KAFKA-6803: -- I think you are right, since all keys are ma

[jira] [Commented] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events

[ https://issues.apache.org/jira/browse/KAFKA-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742653#comment-16742653 ] Guozhang Wang commented on KAFKA-7748: -- [~jonathanpdx] I've added you to the wiki sp

[jira] [Commented] (KAFKA-7461) Connect Values converter should have coverage of logical types

[ https://issues.apache.org/jira/browse/KAFKA-7461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742587#comment-16742587 ] ASF GitHub Bot commented on KAFKA-7461: --- ewencp commented on pull request #6077: KA

[jira] [Resolved] (KAFKA-7461) Connect Values converter should have coverage of logical types

[ https://issues.apache.org/jira/browse/KAFKA-7461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7461. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 60

[jira] [Resolved] (KAFKA-7818) Make the KafkaConsumer AutoCloseable

[ https://issues.apache.org/jira/browse/KAFKA-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fokko Driesprong resolved KAFKA-7818. - Resolution: Invalid > Make the KafkaConsumer AutoCloseable >

[jira] [Commented] (KAFKA-7818) Make the KafkaConsumer AutoCloseable

[ https://issues.apache.org/jira/browse/KAFKA-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742580#comment-16742580 ] ASF GitHub Bot commented on KAFKA-7818: --- Fokko commented on pull request #6142: [KA

[jira] [Commented] (KAFKA-7820) distinct count kafka streams api

[ https://issues.apache.org/jira/browse/KAFKA-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742549#comment-16742549 ] Boyang Chen commented on KAFKA-7820: Hey Vinoth, thanks for proposing this! Based on

[jira] [Resolved] (KAFKA-7503) Integration Test Framework for Connect

[ https://issues.apache.org/jira/browse/KAFKA-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7503. -- Resolution: Fixed Fix Version/s: 2.0.2 2.1.1

[jira] [Commented] (KAFKA-7789) SSL-related unit tests hang when run on Fedora 29

[ https://issues.apache.org/jira/browse/KAFKA-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742533#comment-16742533 ] ASF GitHub Bot commented on KAFKA-7789: --- junrao commented on pull request #6096: KA

[jira] [Commented] (KAFKA-7503) Integration Test Framework for Connect

[ https://issues.apache.org/jira/browse/KAFKA-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742532#comment-16742532 ] ASF GitHub Bot commented on KAFKA-7503: --- ewencp commented on pull request #5516: KA

[jira] [Updated] (KAFKA-7821) Streams: default cache size can lose session windows in high-throughput deployment

[ https://issues.apache.org/jira/browse/KAFKA-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew Jarvie updated KAFKA-7821: -- Summary: Streams: default cache size can lose session windows in high-throughput deployment (w

[jira] [Created] (KAFKA-7821) Default cache size can lose session windows in high-throughput deployment

Matthew Jarvie created KAFKA-7821: - Summary: Default cache size can lose session windows in high-throughput deployment Key: KAFKA-7821 URL: https://issues.apache.org/jira/browse/KAFKA-7821 Project: Ka

[jira] [Commented] (KAFKA-7815) SourceTask should expose ACK'd offsets, metadata

[ https://issues.apache.org/jira/browse/KAFKA-7815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742500#comment-16742500 ] Ryanne Dolan commented on KAFKA-7815: - thanks [~mjsax], changed to 416. Concurrency i

[jira] [Resolved] (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:all-tabpanel ] Kan Li resolved KAFKA-6627. --- Resolution: Fixed > Console producer default config values override explicitly provided properties >

[jira] [Created] (KAFKA-7820) distinct count kafka streams api

Vinoth Rajasekar created KAFKA-7820: --- Summary: distinct count kafka streams api Key: KAFKA-7820 URL: https://issues.apache.org/jira/browse/KAFKA-7820 Project: Kafka Issue Type: New Feature

[jira] [Assigned] (KAFKA-7817) Multiple Consumer Group Management with Regex

[ https://issues.apache.org/jira/browse/KAFKA-7817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky reassigned KAFKA-7817: -- Assignee: Alex Dunayevsky > Multiple Consumer Group Management with Regex > --

[jira] [Commented] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events

[ https://issues.apache.org/jira/browse/KAFKA-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742434#comment-16742434 ] John Roesler commented on KAFKA-7748: - Hi [~jonathanpdx], if you're wiling, it would

[jira] [Commented] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist

[ https://issues.apache.org/jira/browse/KAFKA-7633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742398#comment-16742398 ] Arabelle Hou commented on KAFKA-7633: - Hey [~gavriep], do you mind taking a look at t

[jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742324#comment-16742324 ] Matthias J. Sax commented on KAFKA-4850: [~bharatviswa], it seems your PR was nev

[jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742347#comment-16742347 ] Bharat Viswanadham commented on KAFKA-4850: --- [~mjsax] Sure go ahead. Thanks. >

[jira] [Resolved] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found

[ https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7808. -- Resolution: Fixed Fix Version/s: 2.2.0 > AdminClient#describeTopics should not throw Inv

[jira] [Updated] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7672: --- Description: Normally, when a task is migrated to a new thread and no checkpoint file was fo

[jira] [Updated] (KAFKA-7818) Make the KafkaConsumer AutoCloseable

[ https://issues.apache.org/jira/browse/KAFKA-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7818: --- Component/s: (was: core) clients > Make the KafkaConsumer AutoCloseable

[jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742322#comment-16742322 ] Matthias J. Sax commented on KAFKA-4850: [~zirx] In fact, [~bbejeck] opened a PR

[jira] [Commented] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found

[ https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742320#comment-16742320 ] Guozhang Wang commented on KAFKA-7808: -- [~dongjin] I've left a comment on the PR abo

[jira] [Commented] (KAFKA-7818) Make the KafkaConsumer AutoCloseable

[ https://issues.apache.org/jira/browse/KAFKA-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742314#comment-16742314 ] Matthias J. Sax commented on KAFKA-7818:  Consumer as well as Producer implement

[jira] [Updated] (KAFKA-7818) Make the KafkaConsumer AutoCloseable

[ https://issues.apache.org/jira/browse/KAFKA-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7818: --- Labels: needs-kip (was: ) > Make the KafkaConsumer AutoCloseable > -

[jira] [Commented] (KAFKA-7807) Special Characters in Topic Name Appear to Break Replication

[ https://issues.apache.org/jira/browse/KAFKA-7807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742312#comment-16742312 ] Joseph Niemiec commented on KAFKA-7807: --- Saddly I am unsure how the dev team create

[jira] [Updated] (KAFKA-7818) Make the KafkaConsumer AutoCloseable

[ https://issues.apache.org/jira/browse/KAFKA-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7818: --- Issue Type: Improvement (was: Bug) > Make the KafkaConsumer AutoCloseable >

[jira] [Comment Edited] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742250#comment-16742250 ] Dmitry Buykin edited comment on KAFKA-4850 at 1/14/19 4:31 PM:

[jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742250#comment-16742250 ] Dmitry Buykin commented on KAFKA-4850: -- Hi [~mjsax], any update on this task? Could

[jira] [Created] (KAFKA-7819) Trogdor - Improve RoundTripWorker

Stanislav Kozlovski created KAFKA-7819: -- Summary: Trogdor - Improve RoundTripWorker Key: KAFKA-7819 URL: https://issues.apache.org/jira/browse/KAFKA-7819 Project: Kafka Issue Type: Impro

[jira] [Commented] (KAFKA-7805) Use --bootstrap-server option in ducktape tests where applicable

[ https://issues.apache.org/jira/browse/KAFKA-7805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742138#comment-16742138 ] ASF GitHub Bot commented on KAFKA-7805: --- viktorsomogyi commented on pull request #6

[jira] [Resolved] (KAFKA-4325) Improve processing of late records for window operations

[ https://issues.apache.org/jira/browse/KAFKA-4325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-4325. - Resolution: Fixed Fix Version/s: 2.1.0 As [~mjsax] noted, this need was satisfied by KAFKA

[jira] [Commented] (KAFKA-7818) Make the KafkaConsumer AutoCloseable

[ https://issues.apache.org/jira/browse/KAFKA-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742033#comment-16742033 ] ASF GitHub Bot commented on KAFKA-7818: --- Fokko commented on pull request #6142: [KA

[jira] [Created] (KAFKA-7818) Make the KafkaConsumer AutoCloseable

Fokko Driesprong created KAFKA-7818: --- Summary: Make the KafkaConsumer AutoCloseable Key: KAFKA-7818 URL: https://issues.apache.org/jira/browse/KAFKA-7818 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7297) Both read/write access to Log.segments should be protected by lock

[ https://issues.apache.org/jira/browse/KAFKA-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741921#comment-16741921 ] Zhanxiang (Patrick) Huang commented on KAFKA-7297: -- Sorry for being late

[jira] [Updated] (KAFKA-7817) Multiple Consumer Group Management with Regex

[ https://issues.apache.org/jira/browse/KAFKA-7817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-7817: --- Description: //TODO: New feature: Provide ConsumerGroupCommand with ability to query/manage

[jira] [Created] (KAFKA-7817) Multiple Consumer Group Management with Regex

Alex Dunayevsky created KAFKA-7817: -- Summary: Multiple Consumer Group Management with Regex Key: KAFKA-7817 URL: https://issues.apache.org/jira/browse/KAFKA-7817 Project: Kafka Issue Type: N

[jira] [Commented] (KAFKA-7802) Connection to Broker Disconnected Taking Down the Whole Cluster

[ https://issues.apache.org/jira/browse/KAFKA-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741843#comment-16741843 ] Candice Wan commented on KAFKA-7802: when 2.1.1 is expected to be released? > Connec

[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&focusedCommentId=16741847#comment-16741847 ] Ismael Juma commented on KAFKA-1194: Promising that Windows 10 seems to support posix

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741845#comment-16741845 ] GaoLiang commented on KAFKA-4477: - We meet the same issue on a fresh install of Kafka 2.1

[jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741842#comment-16741842 ] Candice Wan commented on KAFKA-7697: when 2.1.1 is expected to be released? > Possib

[jira] [Commented] (KAFKA-6582) Partitions get underreplicated, with a single ISR, and doesn't recover. Other brokers do not take over and we need to manually restart the broker.

[ https://issues.apache.org/jira/browse/KAFKA-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741840#comment-16741840 ] GaoLiang commented on KAFKA-6582: - Almost the same issue with a fresh install of version