[jira] [Commented] (KAFKA-8477) Cannot consume and request metadata for __consumer_offsets topic in Kafka 2.2

2020-01-08 Thread Steven Aerts (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011524#comment-17011524 ] Steven Aerts commented on KAFKA-8477: - Wondering if this might be related to the fix done in

[jira] [Commented] (KAFKA-9389) Document how to use kafka-reassign-partitions.sh to change log dirs for a partition

2020-01-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011495#comment-17011495 ] ASF GitHub Bot commented on KAFKA-9389: --- mitchell-h commented on pull request #7916: KAFKA-9389 -

[jira] [Commented] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

2020-01-08 Thread Andy Bryant (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011427#comment-17011427 ] Andy Bryant commented on KAFKA-9390: Also I'm using the 2.4 version of Kafka Streams with 5.3.2

[jira] [Comment Edited] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

2020-01-08 Thread Andy Bryant (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011426#comment-17011426 ] Andy Bryant edited comment on KAFKA-9390 at 1/9/20 5:25 AM: Here's the code

[jira] [Commented] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

2020-01-08 Thread Andy Bryant (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011426#comment-17011426 ] Andy Bryant commented on KAFKA-9390: Here's the code snipped. I'm joining the orders table to the

[jira] [Created] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

2020-01-08 Thread Andy Bryant (Jira)
Andy Bryant created KAFKA-9390: -- Summary: Non-key joining of KTable not compatible with confluent avro serdes Key: KAFKA-9390 URL: https://issues.apache.org/jira/browse/KAFKA-9390 Project: Kafka

[jira] [Resolved] (KAFKA-9068) Fix incorrect JavaDocs for `Stores.xxxSessionStore(...)`

2020-01-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9068. Fix Version/s: 2.4.1 2.3.2 2.5.0 Resolution:

[jira] [Commented] (KAFKA-9068) Fix incorrect JavaDocs for `Stores.xxxSessionStore(...)`

2020-01-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011356#comment-17011356 ] ASF GitHub Bot commented on KAFKA-9068: --- mjsax commented on pull request #7908: KAFKA-9068: Fix

[jira] [Commented] (KAFKA-9341) Flaky Test TopicCommandWithAdminClientTest#testCreateWithReplicaAssignment

2020-01-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011354#comment-17011354 ] Matthias J. Sax commented on KAFKA-9341:

[jira] [Commented] (KAFKA-9176) Flaky test failure: OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyStore

2020-01-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011351#comment-17011351 ] Matthias J. Sax commented on KAFKA-9176:

[jira] [Commented] (KAFKA-9075) Extend documentation for usage of GlobalKTable vs KTable

2020-01-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011311#comment-17011311 ] Matthias J. Sax commented on KAFKA-9075: Feel free to pick it up :) > Extend documentation for

[jira] [Commented] (KAFKA-9290) Update IQ related JavaDocs

2020-01-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011309#comment-17011309 ] Matthias J. Sax commented on KAFKA-9290: Sure. Note that there is some overlap with KAFKA-9243 

[jira] [Commented] (KAFKA-9152) Improve Sensor Retrieval

2020-01-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011300#comment-17011300 ] ASF GitHub Bot commented on KAFKA-9152: --- highluck commented on pull request #7914: KAFKA-9152;

[jira] [Resolved] (KAFKA-9384) Loop improvements

2020-01-08 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9384. -- Fix Version/s: (was: 2.4.0) 2.5.0 Resolution: Fixed > Loop

[jira] [Commented] (KAFKA-9384) Loop improvements

2020-01-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011285#comment-17011285 ] ASF GitHub Bot commented on KAFKA-9384: --- guozhangwang commented on pull request #7907: KAFKA-9384;

[jira] [Updated] (KAFKA-9377) Refactor StreamsPartitionAssignor Repartition Count logic

2020-01-08 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9377: --- Description: The current repartition count uses a big while loop to randomly initialize each

[jira] [Resolved] (KAFKA-8988) Replace CreatePartitions request/response with automated protocol

2020-01-08 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8988. Fix Version/s: 2.5.0 Resolution: Fixed > Replace CreatePartitions request/response

[jira] [Commented] (KAFKA-8988) Replace CreatePartitions request/response with automated protocol

2020-01-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011081#comment-17011081 ] ASF GitHub Bot commented on KAFKA-8988: --- hachikuji commented on pull request #7493: KAFKA-8988.

[jira] [Assigned] (KAFKA-9152) Improve Sensor Retrieval

2020-01-08 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck reassigned KAFKA-9152: --- Assignee: highluck (was: Hardik Tewari) > Improve Sensor Retrieval > - >

[jira] [Resolved] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2020-01-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6049. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Streams: Add Cogroup in the DSL >

[jira] [Commented] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2020-01-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011070#comment-17011070 ] ASF GitHub Bot commented on KAFKA-6049: --- mjsax commented on pull request #7847: KAFKA-6049: extend

[jira] [Created] (KAFKA-9389) Document how to use kafka-reassign-partitions.sh to change log dirs for a partition

2020-01-08 Thread James Cheng (Jira)
James Cheng created KAFKA-9389: -- Summary: Document how to use kafka-reassign-partitions.sh to change log dirs for a partition Key: KAFKA-9389 URL: https://issues.apache.org/jira/browse/KAFKA-9389

[jira] [Created] (KAFKA-9388) Flaky Test StandbyTaskCreationIntegrationTest.shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables

2020-01-08 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9388: -- Summary: Flaky Test StandbyTaskCreationIntegrationTest.shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables Key: KAFKA-9388 URL:

[jira] [Assigned] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

2020-01-08 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-4969: -- Assignee: (was: Bill Bejeck) > State-store workload-aware StreamsPartitionAssignor >

[jira] [Commented] (KAFKA-9385) Connect cluster: connector task repeat like a splitbrain cluster problem

2020-01-08 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010955#comment-17010955 ] Randall Hauch commented on KAFKA-9385: -- [~kaikai.hou], what version of Apache Kafka Connect are you

[jira] [Commented] (KAFKA-9386) Flaky test AclAuthorizerTest.testHighConcurrencyDeletionOfResourceAcls

2020-01-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010917#comment-17010917 ] ASF GitHub Bot commented on KAFKA-9386: --- rajinisivaram commented on pull request #7911: KAFKA-9386;

[jira] [Commented] (KAFKA-4898) Add timeouts to streams integration tests

2020-01-08 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010862#comment-17010862 ] Colin McCabe commented on KAFKA-4898: - Sorry if this is a silly question, but can you explain why

[jira] [Assigned] (KAFKA-9384) Loop improvements

2020-01-08 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-9384: Assignee: highluck > Loop improvements > -- > > Key:

[jira] [Commented] (KAFKA-9384) Loop improvements

2020-01-08 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010841#comment-17010841 ] Guozhang Wang commented on KAFKA-9384: -- [~high.lee] I've added you as a contributor and assign this

[jira] [Commented] (KAFKA-9387) LZ4 Compression creates significant unnecessary CPU usage

2020-01-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010835#comment-17010835 ] ASF GitHub Bot commented on KAFKA-9387: --- CodingFabian commented on pull request #7910: KAFKA-9387:

[jira] [Created] (KAFKA-9387) LZ4 Compression creates significant unnecessary CPU usage

2020-01-08 Thread Fabian Lange (Jira)
Fabian Lange created KAFKA-9387: --- Summary: LZ4 Compression creates significant unnecessary CPU usage Key: KAFKA-9387 URL: https://issues.apache.org/jira/browse/KAFKA-9387 Project: Kafka Issue

[jira] [Resolved] (KAFKA-8868) Consider auto-generating Streams binary protocol messages

2020-01-08 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-8868. - Resolution: Fixed > Consider auto-generating Streams binary protocol messages >

[jira] [Created] (KAFKA-9386) Flaky test AclAuthorizerTest.testHighConcurrencyDeletionOfResourceAcls

2020-01-08 Thread Rajini Sivaram (Jira)
Rajini Sivaram created KAFKA-9386: - Summary: Flaky test AclAuthorizerTest.testHighConcurrencyDeletionOfResourceAcls Key: KAFKA-9386 URL: https://issues.apache.org/jira/browse/KAFKA-9386 Project:

[jira] [Commented] (KAFKA-8398) NPE when unmapping files after moving log directories using AlterReplicaLogDirs

2020-01-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010693#comment-17010693 ] ASF GitHub Bot commented on KAFKA-8398: --- jaikiran commented on pull request #7387: [2.2 branch]

[jira] [Updated] (KAFKA-8959) Update Guava to 24 (or newer) or remove dependency

2020-01-08 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-8959: --- Fix Version/s: (was: 2.5.0) > Update Guava to 24 (or newer) or remove dependency >

[jira] [Resolved] (KAFKA-8959) Update Guava to 24 (or newer) or remove dependency

2020-01-08 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-8959. Resolution: Duplicate Marking this as a duplicate of KAFKA-3061 since the newest version of

[jira] [Commented] (KAFKA-3061) Get rid of Guava dependency

2020-01-08 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010692#comment-17010692 ] Ismael Juma commented on KAFKA-3061: Reflections 0.9.12 no longer depends on Guava. > Get rid of

[jira] [Assigned] (KAFKA-3061) Get rid of Guava dependency

2020-01-08 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3061: -- Assignee: Ismael Juma (was: Rekha Joshi) > Get rid of Guava dependency >

[jira] [Updated] (KAFKA-3061) Get rid of Guava dependency

2020-01-08 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3061: --- Fix Version/s: 2.5.0 > Get rid of Guava dependency > --- > >

[jira] [Updated] (KAFKA-9385) Connect cluster: connector task repeat like a splitbrain cluster problem

2020-01-08 Thread kaikai.hou (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaikai.hou updated KAFKA-9385: -- Description: I am using Debezium. And find a task repeat

[jira] [Created] (KAFKA-9385) Connect cluster: connector task repeat like a splitbrain cluster problem

2020-01-08 Thread kaikai.hou (Jira)
kaikai.hou created KAFKA-9385: - Summary: Connect cluster: connector task repeat like a splitbrain cluster problem Key: KAFKA-9385 URL: https://issues.apache.org/jira/browse/KAFKA-9385 Project: Kafka

[jira] [Commented] (KAFKA-9374) Worker can be disabled by blocked connectors

2020-01-08 Thread Tom Bentley (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010527#comment-17010527 ] Tom Bentley commented on KAFKA-9374: [~ChrisEgerton] yeah, I agree there's no tenable alternative for

[jira] [Commented] (KAFKA-9384) Loop improvements

2020-01-08 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010523#comment-17010523 ] highluck commented on KAFKA-9384: - [~ableegoldman] Could you assign me a ticket? > Loop improvements >

[jira] [Commented] (KAFKA-9075) Extend documentation for usage of GlobalKTable vs KTable

2020-01-08 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010509#comment-17010509 ] highluck commented on KAFKA-9075: - [~bchen225242] [~mjsax] Shall I take this up. i'm new bie try it >

[jira] [Updated] (KAFKA-9384) Loop improvements

2020-01-08 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck updated KAFKA-9384: Priority: Minor (was: Major) > Loop improvements > -- > > Key: