[jira] [Issue Comment Deleted] (KAFKA-7814) Broker shut down while cleaning up log file

[ https://issues.apache.org/jira/browse/KAFKA-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ishwor updated KAFKA-7814: -- Comment: was deleted (was: [...] It's fixed in `1.1.1`. It's time to upgrade your broker. ) > Broker shut

[jira] [Commented] (KAFKA-7814) Broker shut down while cleaning up log file

[ https://issues.apache.org/jira/browse/KAFKA-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744006#comment-16744006 ] Ishwor commented on KAFKA-7814: --- Ignore my earlier reply. Saw that you upgraded to `2.1.0` and I thought

[jira] [Commented] (KAFKA-7828) Execute Trogdor tasks with external commands

[ https://issues.apache.org/jira/browse/KAFKA-7828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744026#comment-16744026 ] ASF GitHub Bot commented on KAFKA-7828: --- yangxi commented on pull request #6156: KAFKA-7828:

[jira] [Commented] (KAFKA-7814) Broker shut down while cleaning up log file

[ https://issues.apache.org/jira/browse/KAFKA-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743987#comment-16743987 ] Ishwor commented on KAFKA-7814: --- [...] It's fixed in `1.1.1`. It's time to upgrade your broker. >

[jira] [Commented] (KAFKA-7827) Consumer stops receiving messages when FIRST leader started is killed

[ https://issues.apache.org/jira/browse/KAFKA-7827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743996#comment-16743996 ] Somnath Choudhuri commented on KAFKA-7827: -- Topic has 3 replicas. The error only happens is the

[jira] [Updated] (KAFKA-7828) Execute Trogdor tasks with external commands

[ https://issues.apache.org/jira/browse/KAFKA-7828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xi Yang updated KAFKA-7828: --- Summary: Execute Trogdor tasks with external commands (was: Add Trogdor ExternalCommandSpec and

[jira] [Commented] (KAFKA-3370) Add options to auto.offset.reset to reset offsets upon initialization only

[ https://issues.apache.org/jira/browse/KAFKA-3370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744265#comment-16744265 ] Tayida Tapjinda commented on KAFKA-3370: [~guozhang] Is this still needed? We have implemented

[jira] [Commented] (KAFKA-7829) Inaccurate description for --reassignment-json-file option in ReassignPartitionsCommand

[ https://issues.apache.org/jira/browse/KAFKA-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744272#comment-16744272 ] Jun Rao commented on KAFKA-7829: [~lindong], could you verify if this is inaccurate? > Inaccurate

[jira] [Commented] (KAFKA-4113) Allow KTable bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744273#comment-16744273 ] Matthias J. Sax commented on KAFKA-4113: KTable-KTable join should not be effected because both

[jira] [Commented] (KAFKA-7829) Inaccurate description for --reassignment-json-file option in ReassignPartitionsCommand

[ https://issues.apache.org/jira/browse/KAFKA-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744321#comment-16744321 ] Dong Lin commented on KAFKA-7829: - [~junrao] Yeah this is inaccurate after

[jira] [Updated] (KAFKA-4107) Support offset reset capability in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-4107: - Labels: needs-kip (was: ) > Support offset reset capability in Kafka Connect >

[jira] [Updated] (KAFKA-7829) Javadoc should show that alterReplicaLogDirs() is supported in Kafka 1.1.0 or later

[ https://issues.apache.org/jira/browse/KAFKA-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7829: Description: In ReassignPartitionsCommand, the --reassignment-json-file option says "...If absolute log

[jira] [Updated] (KAFKA-7829) Javadoc should show that alterReplicaLogDirs() is supported in Kafka 1.1.0 or later

[ https://issues.apache.org/jira/browse/KAFKA-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7829: Summary: Javadoc should show that alterReplicaLogDirs() is supported in Kafka 1.1.0 or later (was:

[jira] [Updated] (KAFKA-7829) Javadoc should show that AdminClient.alterReplicaLogDirs() is supported in Kafka 1.1.0 or later

[ https://issues.apache.org/jira/browse/KAFKA-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7829: Summary: Javadoc should show that AdminClient.alterReplicaLogDirs() is supported in Kafka 1.1.0 or later

[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=16744195#comment-16744195 ] Navinder Brar commented on KAFKA-7149: -- [~mjsax] The PR has passed all the checks and code review

[jira] [Created] (KAFKA-7829) Inaccurate description for --reassignment-json-file option in ReassignPartitionsCommand

Jun Rao created KAFKA-7829: -- Summary: Inaccurate description for --reassignment-json-file option in ReassignPartitionsCommand Key: KAFKA-7829 URL: https://issues.apache.org/jira/browse/KAFKA-7829 Project:

[jira] [Assigned] (KAFKA-7829) Inaccurate description for --reassignment-json-file option in ReassignPartitionsCommand

[ https://issues.apache.org/jira/browse/KAFKA-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-7829: --- Assignee: Dong Lin > Inaccurate description for --reassignment-json-file option in >

[jira] [Commented] (KAFKA-7829) Javadoc should show that AdminClient.alterReplicaLogDirs() is supported in Kafka 1.1.0 or later

[ https://issues.apache.org/jira/browse/KAFKA-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744332#comment-16744332 ] ASF GitHub Bot commented on KAFKA-7829: --- lindong28 commented on pull request #6157: KAFKA-7829;

[jira] [Updated] (KAFKA-7788) Support null defaults in KAFKA-7609 RPC specifications

[ https://issues.apache.org/jira/browse/KAFKA-7788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7788: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-7830 > Support null defaults

[jira] [Updated] (KAFKA-7609) Add Protocol Generator for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-7609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7609: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-7830 > Add Protocol Generator

[jira] [Created] (KAFKA-7831) Consumer SubscriptionState missing synchronization

Jason Gustafson created KAFKA-7831: -- Summary: Consumer SubscriptionState missing synchronization Key: KAFKA-7831 URL: https://issues.apache.org/jira/browse/KAFKA-7831 Project: Kafka Issue

[jira] [Created] (KAFKA-7832) Use automatic RPC generation in CreateTopics

Colin P. McCabe created KAFKA-7832: -- Summary: Use automatic RPC generation in CreateTopics Key: KAFKA-7832 URL: https://issues.apache.org/jira/browse/KAFKA-7832 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7223) KIP-328: Add in-memory Suppression

[ https://issues.apache.org/jira/browse/KAFKA-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744485#comment-16744485 ] Matthias J. Sax commented on KAFKA-7223: Ack. Fine with me. (Maybe good to have this documented

[jira] [Created] (KAFKA-7830) Convert Kafka RPCs to use automatically generated code

Colin P. McCabe created KAFKA-7830: -- Summary: Convert Kafka RPCs to use automatically generated code Key: KAFKA-7830 URL: https://issues.apache.org/jira/browse/KAFKA-7830 Project: Kafka

[jira] [Commented] (KAFKA-7699) Improve wall-clock time punctuations

[ https://issues.apache.org/jira/browse/KAFKA-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744402#comment-16744402 ] Yishun Guan commented on KAFKA-7699: [~mjsax] Oh I see now I have more context. Thanks! > Improve

[jira] [Commented] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores

[ https://issues.apache.org/jira/browse/KAFKA-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744463#comment-16744463 ] Matthias J. Sax commented on KAFKA-6499: [~guozhang] This seems to be fixed in 2.0.0 but not 1.1

[jira] [Created] (KAFKA-7833) StreamsBuilder should throw an exception if addGlobalStore and addStateStore is called for the same store builder

Sam Lendle created KAFKA-7833: - Summary: StreamsBuilder should throw an exception if addGlobalStore and addStateStore is called for the same store builder Key: KAFKA-7833 URL:

[jira] [Commented] (KAFKA-7834) Extend collected logs in system test services to include heap dumps

[ https://issues.apache.org/jira/browse/KAFKA-7834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744401#comment-16744401 ] ASF GitHub Bot commented on KAFKA-7834: --- kkonstantine commented on pull request #6158: KAFKA-7834:

[jira] [Assigned] (KAFKA-4304) Extend Interactive Queries for return latest update timestamp per key

[ https://issues.apache.org/jira/browse/KAFKA-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4304: -- Assignee: Matthias J. Sax > Extend Interactive Queries for return latest update

[jira] [Updated] (KAFKA-4304) Extend Interactive Queries for return latest update timestamp per key

[ https://issues.apache.org/jira/browse/KAFKA-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4304: --- Labels: kip (was: needs-kip) > Extend Interactive Queries for return latest update

[jira] [Updated] (KAFKA-4304) Extend Interactive Queries for return latest update timestamp per key

[ https://issues.apache.org/jira/browse/KAFKA-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4304: --- Description: Currently, when querying state store, it is not clear when the key was updated

[jira] [Updated] (KAFKA-7787) Add error specifications to KAFKA-7609

[ https://issues.apache.org/jira/browse/KAFKA-7787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7787: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-7830 > Add error

[jira] [Commented] (KAFKA-7223) KIP-328: Add in-memory Suppression

[ https://issues.apache.org/jira/browse/KAFKA-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744462#comment-16744462 ] Matthias J. Sax commented on KAFKA-7223: Ping [~guozhang] and [~vvcephei] about my comment above.

[jira] [Created] (KAFKA-7834) Extend collected logs in system test services to include heap dumps

Konstantine Karantasis created KAFKA-7834: - Summary: Extend collected logs in system test services to include heap dumps Key: KAFKA-7834 URL: https://issues.apache.org/jira/browse/KAFKA-7834

[jira] [Commented] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores

[ https://issues.apache.org/jira/browse/KAFKA-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744655#comment-16744655 ] Guozhang Wang commented on KAFKA-6499: -- You're right. Fixing. > Avoid creating dummy checkpoint

[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=16744663#comment-16744663 ] Guozhang Wang commented on KAFKA-7820: -- [~vinubarro] Thanks for sharing your use case. I think the

[jira] [Commented] (KAFKA-6687) Allow to read a topic multiple times

[ https://issues.apache.org/jira/browse/KAFKA-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744548#comment-16744548 ] Matthias J. Sax commented on KAFKA-6687: One side remark about this ticket: if we allow to read a

[jira] [Commented] (KAFKA-7223) KIP-328: Add in-memory Suppression

[ https://issues.apache.org/jira/browse/KAFKA-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744653#comment-16744653 ] Guozhang Wang commented on KAFKA-7223: -- Sounds good to me too：leaving as in 2.1 with documentations

[jira] [Commented] (KAFKA-4218) Enable access to key in ValueTransformer

[ https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744656#comment-16744656 ] Guozhang Wang commented on KAFKA-4218: -- You are right :) Mind creating a new JIRA and fixing this

[jira] [Updated] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores

[ https://issues.apache.org/jira/browse/KAFKA-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6499: - Fix Version/s: (was: 1.1.0) 2.0.0 > Avoid creating dummy checkpoint files

[jira] [Commented] (KAFKA-7833) StreamsBuilder should throw an exception if addGlobalStore and addStateStore is called for the same store builder

[ https://issues.apache.org/jira/browse/KAFKA-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744658#comment-16744658 ] Guozhang Wang commented on KAFKA-7833: -- Could you elaborate a bit more on why we should not allow

[jira] [Comment Edited] (KAFKA-7833) StreamsBuilder should throw an exception if addGlobalStore and addStateStore is called for the same store builder

[ https://issues.apache.org/jira/browse/KAFKA-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744658#comment-16744658 ] Guozhang Wang edited comment on KAFKA-7833 at 1/17/19 3:39 AM: --- Could you

[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=16744741#comment-16744741 ] ASF GitHub Bot commented on KAFKA-7503: --- ewencp commented on pull request #6148: MINOR: Start

[jira] [Commented] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store

[ https://issues.apache.org/jira/browse/KAFKA-7075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16744720#comment-16744720 ] Lionel Montrieux commented on KAFKA-7075: - [~twbecker] I spent some time on this yesterday. I

[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=16744765#comment-16744765 ] ASF GitHub Bot commented on KAFKA-7149: --- brary commented on pull request #6162: KAFKA-7149 Reduce

[jira] [Commented] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

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

[jira] [Comment Edited] (KAFKA-4113) Allow KTable bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743260#comment-16743260 ] Edmondo Porcu edited comment on KAFKA-4113 at 1/16/19 10:52 AM:  I think

[jira] [Resolved] (KAFKA-7814) Broker shut down while cleaning up log file

[ https://issues.apache.org/jira/browse/KAFKA-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] EverZhang resolved KAFKA-7814. -- Resolution: Not A Problem > Broker shut down while cleaning up log file >

[jira] [Commented] (KAFKA-7814) Broker shut down while cleaning up log file

[ https://issues.apache.org/jira/browse/KAFKA-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743754#comment-16743754 ] EverZhang commented on KAFKA-7814: -- Sorry， finally I found some log cleaning scripts delete kafka log