[jira] [Commented] (KAFKA-7382) We shoud guarantee at lest one replica of partition should be alive when create or update topic

[ https://issues.apache.org/jira/browse/KAFKA-7382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699912#comment-16699912 ] ASF GitHub Bot commented on KAFKA-7382: --- sumannewton opened a new pull request #5822: Fixed

[jira] [Commented] (KAFKA-7382) We shoud guarantee at lest one replica of partition should be alive when create or update topic

[ https://issues.apache.org/jira/browse/KAFKA-7382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699906#comment-16699906 ] ASF GitHub Bot commented on KAFKA-7382: --- sumannewton closed pull request #5822: Fixed KAFKA-7382 -

[jira] [Commented] (KAFKA-6971) Passing in help flag to kafka-console-producer should print arg options

[ https://issues.apache.org/jira/browse/KAFKA-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699904#comment-16699904 ] ASF GitHub Bot commented on KAFKA-6971: --- omkreddy closed pull request #5732: KAFKA-6971 Passing in

[jira] [Assigned] (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 ] linyue li reassigned KAFKA-7672: Assignee: linyue li > The local state not fully restored after KafkaStream rebalanced, resulting

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699793#comment-16699793 ] John Roesler commented on KAFKA-7660: - > I did not really find the memory leak you mentioned Huh.

[jira] [Updated] (KAFKA-7110) Windowed changelog keys not deserialized properly by TimeWindowedSerde

[ https://issues.apache.org/jira/browse/KAFKA-7110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7110: --- Description: Backed by KIP:

[jira] [Updated] (KAFKA-7110) Windowed changelog keys not deserialized properly by TimeWindowedSerde

[ https://issues.apache.org/jira/browse/KAFKA-7110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7110: --- Labels: kip (was: ) > Windowed changelog keys not deserialized properly by

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699695#comment-16699695 ] Matthias J. Sax commented on KAFKA-7653: Not sure, what the use case for this would be? Why would

[jira] [Commented] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699680#comment-16699680 ] Matthias J. Sax commented on KAFKA-7443: [~linyli] thanks for the patch. I added you to the list

[jira] [Assigned] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7443: -- Assignee: linyue li (was: John Roesler) > OffsetOutOfRangeException in restoring

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699673#comment-16699673 ] Guozhang Wang commented on KAFKA-7610: -- [~hachikuji] Thanks for the update, from the context I agree

[jira] [Commented] (KAFKA-7676) Compile Kafka failed with Gradle 5.0

[ https://issues.apache.org/jira/browse/KAFKA-7676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699632#comment-16699632 ] Jiangtao Liu commented on KAFKA-7676: - I got compile passed with Gradle 4.10.2, which is the last

[jira] [Updated] (KAFKA-7676) Compile Kafka failed with Gradle 5.0

[ https://issues.apache.org/jira/browse/KAFKA-7676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-7676: Summary: Compile Kafka failed with Gradle 5.0 (was: Kafka compile failed with Gradle 5.0) >

[jira] [Commented] (KAFKA-7676) Compile Kafka failed with Gradle 5.0

[ https://issues.apache.org/jira/browse/KAFKA-7676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699628#comment-16699628 ] Jiangtao Liu commented on KAFKA-7676: - `testClassesDir` is existed in Gradle 4, but not existed in

[jira] [Updated] (KAFKA-7676) Kafka compile failed with Gradle 5.0

[ https://issues.apache.org/jira/browse/KAFKA-7676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-7676: Description: With the version described in README [Kafka requires Gradle 4.7 or

[jira] [Updated] (KAFKA-7676) Kafka compile failed with Gradle 5.0

[ https://issues.apache.org/jira/browse/KAFKA-7676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-7676: Description: With the version described in README [Kafka requires Gradle 4.7 or

[jira] [Created] (KAFKA-7676) Kafka compile failed with Gradle 5.0

Jiangtao Liu created KAFKA-7676: --- Summary: Kafka compile failed with Gradle 5.0 Key: KAFKA-7676 URL: https://issues.apache.org/jira/browse/KAFKA-7676 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699614#comment-16699614 ] Mark Tranter commented on KAFKA-7653: - Thanks [~vvcephei], Different serde instances for keys/values

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699457#comment-16699457 ] Jason Gustafson commented on KAFKA-7610: [~bchen225242] Thanks for posting KIP-394. It looks

[jira] [Commented] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699446#comment-16699446 ] Guozhang Wang commented on KAFKA-5146: -- I think we can actually use the `streams-quickstart` repo,

[jira] [Commented] (KAFKA-7675) Trogdor CLI - Support filter arguments in the '--show-tasks' command

[ https://issues.apache.org/jira/browse/KAFKA-7675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699432#comment-16699432 ] Colin P. McCabe commented on KAFKA-7675: One thing that would be really nice is using

[jira] [Commented] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699397#comment-16699397 ] Sathish Yanamala commented on KAFKA-7508: - Thank you !!   Could you please suggest any kafka

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699383#comment-16699383 ] John Roesler commented on KAFKA-7653: - Hi [~mark.tranter], I haven't looked at the PR yet, but just

[jira] [Created] (KAFKA-7675) Trogdor CLI - Support filter arguments in the '--show-tasks' command

Stanislav Kozlovski created KAFKA-7675: -- Summary: Trogdor CLI - Support filter arguments in the '--show-tasks' command Key: KAFKA-7675 URL: https://issues.apache.org/jira/browse/KAFKA-7675

[jira] [Commented] (KAFKA-6971) Passing in help flag to kafka-console-producer should print arg options

[ https://issues.apache.org/jira/browse/KAFKA-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699309#comment-16699309 ] ASF GitHub Bot commented on KAFKA-6971: --- omkreddy closed pull request #5175: KAFKA-6971: Passing in

[jira] [Commented] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699269#comment-16699269 ] Jonathan Santilli commented on KAFKA-7508: -- Hello [~sathish051] since you are using Java 8, have

[jira] [Updated] (KAFKA-7674) Quick Start Guide steps for managing topics do not work

[ https://issues.apache.org/jira/browse/KAFKA-7674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nathan Long updated KAFKA-7674: --- Description: I'm following the [Apache Kafka Quick Start

[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=16699243#comment-16699243 ] Kobi Hikri commented on KAFKA-1194: --- [~manme...@gmail.com], [~stephane.maa...@gmail.com], For some

[jira] [Created] (KAFKA-7674) Quick Start Guide steps for managing topics do not work

Nathan Long created KAFKA-7674: -- Summary: Quick Start Guide steps for managing topics do not work Key: KAFKA-7674 URL: https://issues.apache.org/jira/browse/KAFKA-7674 Project: Kafka Issue

[jira] [Commented] (KAFKA-6409) LogRecoveryTest (testHWCheckpointWithFailuresSingleLogSegment) is flaky

[ https://issues.apache.org/jira/browse/KAFKA-6409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699165#comment-16699165 ] Stanislav Kozlovski commented on KAFKA-6409: This was fixed by

[jira] [Commented] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699092#comment-16699092 ] Sathish Yanamala commented on KAFKA-7508: - Hi Jonathan Santilli, Thanks for the support ! We

[jira] [Updated] (KAFKA-7673) Upgrade RocksDB to include fix for WinEnvIO::GetSectorSize

[ https://issues.apache.org/jira/browse/KAFKA-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7673: --- Fix Version/s: 2.2.0 > Upgrade RocksDB to include fix for WinEnvIO::GetSectorSize >

[jira] [Updated] (KAFKA-7673) Upgrade RocksDB to include fix for WinEnvIO::GetSectorSize

[ https://issues.apache.org/jira/browse/KAFKA-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7673: --- Issue Type: Improvement (was: Bug) > Upgrade RocksDB to include fix for WinEnvIO::GetSectorSize >

[jira] [Comment Edited] (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=16698875#comment-16698875 ] Kobi Hikri edited comment on KAFKA-1194 at 11/26/18 1:46 PM: - I've created a

[jira] [Commented] (KAFKA-7673) Upgrade RocksDB to include fix for WinEnvIO::GetSectorSize

[ https://issues.apache.org/jira/browse/KAFKA-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16698932#comment-16698932 ] Yanick Salzmann commented on KAFKA-7673: Confimed by upgrading to: org.rocksdb rocksdbjni

[jira] [Created] (KAFKA-7673) Upgrade RocksDB to include fix for WinEnvIO::GetSectorSize

Yanick Salzmann created KAFKA-7673: -- Summary: Upgrade RocksDB to include fix for WinEnvIO::GetSectorSize Key: KAFKA-7673 URL: https://issues.apache.org/jira/browse/KAFKA-7673 Project: Kafka

[jira] [Commented] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic

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

[jira] [Updated] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7443: - Attachment: KAFKA-7443.url > OffsetOutOfRangeException in restoring state store from changelog topic

[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=16698875#comment-16698875 ] Kobi Hikri commented on KAFKA-1194: --- I've created a new pull request:

[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=16698860#comment-16698860 ] ASF GitHub Bot commented on KAFKA-1194: --- kobihikri closed pull request #5933: DO NOT MERGE -

[jira] [Updated] (KAFKA-7443) OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linyue li updated KAFKA-7443: - Description: When restoring local state store from a changelog topic in EOS, kafka stream will

[jira] [Commented] (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:comment-tabpanel=16698803#comment-16698803 ] Boyang Chen commented on KAFKA-7672: Thanks Linyue for reporting and reproducing the bug! In fact, we

[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=16698604#comment-16698604 ] Kobi Hikri commented on KAFKA-1194: --- Hi all, As I want to move forward with my bug fix, I was running

[jira] [Updated] (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:all-tabpanel ] Kobi Hikri updated KAFKA-1194: -- Attachment: image-2018-11-26-10-18-59-381.png > The kafka broker cannot delete the old log files after