[jira] [Commented] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

[ https://issues.apache.org/jira/browse/KAFKA-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900693#comment-16900693 ] Bruno Cadonna commented on KAFKA-8755: -- In a first analysis, I narrowed down the iss

[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=16900634#comment-16900634 ] Navinder Brar commented on KAFKA-7149: -- [~vinoth] yeah feel free to reassign this to

[jira] [Commented] (KAFKA-8750) Utils#murmur2() method switch case block don't have break

[ https://issues.apache.org/jira/browse/KAFKA-8750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900528#comment-16900528 ] yangkun commented on KAFKA-8750: Thank you for reply.I think it's better to add some comm

[jira] [Updated] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

[ https://issues.apache.org/jira/browse/KAFKA-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8755: - Labels: newbie (was: ) > Stand-by Task of an Optimized Source Table Does Not Write Anything to i

[jira] [Commented] (KAFKA-8325) Remove from the incomplete set failed. This should be impossible

[ https://issues.apache.org/jira/browse/KAFKA-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900495#comment-16900495 ] Luke Stephenson commented on KAFKA-8325: I played around further with `batch.size

[jira] [Commented] (KAFKA-8748) Flaky Test DescribeLogDirsRequestTest#testDescribeLogDirsRequest

[ https://issues.apache.org/jira/browse/KAFKA-8748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900466#comment-16900466 ] Matthias J. Sax commented on KAFKA-8748: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8748) Flaky Test DescribeLogDirsRequestTest#testDescribeLogDirsRequest

[ https://issues.apache.org/jira/browse/KAFKA-8748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900465#comment-16900465 ] Matthias J. Sax commented on KAFKA-8748: [https://builds.apache.org/job/kafka-pr-

[jira] [Created] (KAFKA-8757) Flaky Test SaslSslAdminClientIntegrationTest#testIncrementalAlterConfigsForLog4jLogLevelsCanResetLoggerToCurrentRoot

Matthias J. Sax created KAFKA-8757: -- Summary: Flaky Test SaslSslAdminClientIntegrationTest#testIncrementalAlterConfigsForLog4jLogLevelsCanResetLoggerToCurrentRoot Key: KAFKA-8757 URL: https://issues.apache.org/ji

[jira] [Created] (KAFKA-8756) Flaky Test SaslSslAdminClientIntegrationTest#testIncrementalAlterConfigsForLog4jLogLevels

Matthias J. Sax created KAFKA-8756: -- Summary: Flaky Test SaslSslAdminClientIntegrationTest#testIncrementalAlterConfigsForLog4jLogLevels Key: KAFKA-8756 URL: https://issues.apache.org/jira/browse/KAFKA-8756

[jira] [Assigned] (KAFKA-8661) Flaky Test RebalanceSourceConnectorsIntegrationTest#testStartTwoConnectors

[ https://issues.apache.org/jira/browse/KAFKA-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8661: -- Assignee: Randall Hauch > Flaky Test RebalanceSourceConnectorsIntegrationTest#testStar

[jira] [Commented] (KAFKA-8661) Flaky Test RebalanceSourceConnectorsIntegrationTest#testStartTwoConnectors

[ https://issues.apache.org/jira/browse/KAFKA-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900464#comment-16900464 ] Matthias J. Sax commented on KAFKA-8661: [~rhauch] Assigned this ticket to you as

[jira] [Commented] (KAFKA-8661) Flaky Test RebalanceSourceConnectorsIntegrationTest#testStartTwoConnectors

[ https://issues.apache.org/jira/browse/KAFKA-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900463#comment-16900463 ] Matthias J. Sax commented on KAFKA-8661: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900462#comment-16900462 ] Matthias J. Sax commented on KAFKA-8555: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900461#comment-16900461 ] GEORGE LI commented on KAFKA-4084: -- [~jiaxinye] does the patch from https://issues.apac

[jira] [Created] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

Bruno Cadonna created KAFKA-8755: Summary: Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store Key: KAFKA-8755 URL: https://issues.apache.org/jira/browse/KAFKA-8755 P

[jira] [Commented] (KAFKA-8754) Connect API: Expose the list of available transformations

[ https://issues.apache.org/jira/browse/KAFKA-8754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900400#comment-16900400 ] Stéphane Derosiaux commented on KAFKA-8754: --- I did a tiny work from connector-p

[jira] [Updated] (KAFKA-8754) Connect API: Expose the list of available transformations

[ https://issues.apache.org/jira/browse/KAFKA-8754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stéphane Derosiaux updated KAFKA-8754: -- Attachment: image-2019-08-05-22-45-01-527.png > Connect API: Expose the list of availab

[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=16900364#comment-16900364 ] Matthias J. Sax commented on KAFKA-7149: [~vinoth] If there will be no response f

[jira] [Commented] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900351#comment-16900351 ] Matthias J. Sax commented on KAFKA-8736: [~MJarvie] – I added you to the list on

[jira] [Assigned] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8736: -- Assignee: Matthew Jarvie > Performance: ThreadCache uses size() for empty cache check

[jira] [Created] (KAFKA-8754) Connect API: Expose the list of available transformations

Stéphane Derosiaux created KAFKA-8754: - Summary: Connect API: Expose the list of available transformations Key: KAFKA-8754 URL: https://issues.apache.org/jira/browse/KAFKA-8754 Project: Kafka

[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&focusedCommentId=16900305#comment-16900305 ] Stéphane Derosiaux commented on KAFKA-6598: --- The KIP is up:  [https://cwiki.apa

[jira] [Commented] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900304#comment-16900304 ] ASF GitHub Bot commented on KAFKA-8736: --- mjarvie commented on pull request #7164: K

[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&focusedCommentId=16900274#comment-16900274 ] Ashwin Madavan commented on KAFKA-4628: --- Is there a timeline for this feature? > S

[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=16900269#comment-16900269 ] Vinoth Chandar commented on KAFKA-7149: --- Gentle ping again.. [~NaviBrar] Nonethele

[jira] [Created] (KAFKA-8753) Add JMX for number of topics marked for deletion

David Arthur created KAFKA-8753: --- Summary: Add JMX for number of topics marked for deletion Key: KAFKA-8753 URL: https://issues.apache.org/jira/browse/KAFKA-8753 Project: Kafka Issue Type: Impr

[jira] [Commented] (KAFKA-8750) Utils#murmur2() method switch case block don't have break

[ https://issues.apache.org/jira/browse/KAFKA-8750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900121#comment-16900121 ] Alexandre Dupriez commented on KAFKA-8750: -- The waterfall is expected. If say, t

[jira] [Updated] (KAFKA-8752) Ensure plugin classes are instantiable when discovering plugins

[ https://issues.apache.org/jira/browse/KAFKA-8752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-8752: - Description: While running integration tests from the IntelliJ IDE, it appears plugins fa

[jira] [Updated] (KAFKA-8752) Ensure plugin classes are instantiable when discovering plugins

[ https://issues.apache.org/jira/browse/KAFKA-8752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-8752: - Description: While running integration tests from the IntelliJ IDE, it appears plugins fa

[jira] [Updated] (KAFKA-8752) Ensure plugin classes are instantiable when discovering plugins

[ https://issues.apache.org/jira/browse/KAFKA-8752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez updated KAFKA-8752: - Attachment: stacktrace.log > Ensure plugin classes are instantiable when discovering plug

[jira] [Created] (KAFKA-8752) Ensure plugin classes are instantiable when discovering plugins

Alexandre Dupriez created KAFKA-8752: Summary: Ensure plugin classes are instantiable when discovering plugins Key: KAFKA-8752 URL: https://issues.apache.org/jira/browse/KAFKA-8752 Project: Kafka

[jira] [Created] (KAFKA-8751) Trogdor - Add endpoint that deletes all tasks

Stanislav Kozlovski created KAFKA-8751: -- Summary: Trogdor - Add endpoint that deletes all tasks Key: KAFKA-8751 URL: https://issues.apache.org/jira/browse/KAFKA-8751 Project: Kafka Issue

[jira] [Created] (KAFKA-8750) Utils#murmur2() method switch case block don't have break

yangkun created KAFKA-8750: -- Summary: Utils#murmur2() method switch case block don't have break Key: KAFKA-8750 URL: https://issues.apache.org/jira/browse/KAFKA-8750 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16899894#comment-16899894 ] Bruno Cadonna commented on KAFKA-6647: -- Besides Windows OS, the issue also seems to

[jira] [Comment Edited] (KAFKA-7941) Connect KafkaBasedLog work thread terminates when getting offsets fails because broker is unavailable

[ https://issues.apache.org/jira/browse/KAFKA-7941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16899851#comment-16899851 ] Ivan Yurchenko edited comment on KAFKA-7941 at 8/5/19 7:59 AM:

[jira] [Comment Edited] (KAFKA-7941) Connect KafkaBasedLog work thread terminates when getting offsets fails because broker is unavailable

[ https://issues.apache.org/jira/browse/KAFKA-7941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16899851#comment-16899851 ] Ivan Yurchenko edited comment on KAFKA-7941 at 8/5/19 7:58 AM:

[jira] [Commented] (KAFKA-7941) Connect KafkaBasedLog work thread terminates when getting offsets fails because broker is unavailable

[ https://issues.apache.org/jira/browse/KAFKA-7941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16899851#comment-16899851 ] Ivan Yurchenko commented on KAFKA-7941: --- We got hit by this issue as well. In our c