[jira] [Created] (KAFKA-6697) JBOD configured broker should not die if log directory is invalid

Dong Lin created KAFKA-6697: --- Summary: JBOD configured broker should not die if log directory is invalid Key: KAFKA-6697 URL: https://issues.apache.org/jira/browse/KAFKA-6697 Project: Kafka Issue

[jira] [Commented] (KAFKA-6685) Connect deserialization log message should distinguish key from value

[ https://issues.apache.org/jira/browse/KAFKA-6685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407436#comment-16407436 ] Jagadesh Adireddi commented on KAFKA-6685: -- Hi , I am unable to assign this issue to myself. I

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407378#comment-16407378 ] Narayan Periwal commented on KAFKA-6681: [~yuzhih...@gmail.com] The partition read by the two

[jira] [Commented] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407352#comment-16407352 ] Ewen Cheslack-Postava commented on KAFKA-3821: -- So a couple of points -- * That new

[jira] [Updated] (KAFKA-6673) Segment and Stamped implement Comparable, but don't override equals.

[ https://issues.apache.org/jira/browse/KAFKA-6673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Asutosh Pandya updated KAFKA-6673: -- Attachment: KAFKA_6673.patch > Segment and Stamped implement Comparable, but don't override

[jira] [Created] (KAFKA-6696) Trogdor should support destroying tasks

Colin P. McCabe created KAFKA-6696: -- Summary: Trogdor should support destroying tasks Key: KAFKA-6696 URL: https://issues.apache.org/jira/browse/KAFKA-6696 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6695) Add a system test for dynamic broker config update

Rajini Sivaram created KAFKA-6695: - Summary: Add a system test for dynamic broker config update Key: KAFKA-6695 URL: https://issues.apache.org/jira/browse/KAFKA-6695 Project: Kafka Issue

[jira] [Created] (KAFKA-6694) The Trogdor Coordinator should support filtering task responses

Colin P. McCabe created KAFKA-6694: -- Summary: The Trogdor Coordinator should support filtering task responses Key: KAFKA-6694 URL: https://issues.apache.org/jira/browse/KAFKA-6694 Project: Kafka

[jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests

[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5943: -- Description: Currently connector tests make heavy use of mock (easymock, power mock). This may hide the real

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407036#comment-16407036 ] Ted Yu commented on KAFKA-6681: --- {code} [2018-03-14 05:04:13,231] ERROR [ReplicaFetcherThread-0-15], Error

[jira] [Created] (KAFKA-6693) Add Consumer-only benchmark workload to Trogdor

Anna Povzner created KAFKA-6693: --- Summary: Add Consumer-only benchmark workload to Trogdor Key: KAFKA-6693 URL: https://issues.apache.org/jira/browse/KAFKA-6693 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-6683) ReplicaFetcher crashes with "Attempted to complete a transaction which was not started"

[ https://issues.apache.org/jira/browse/KAFKA-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406835#comment-16406835 ] Chema Sanchez commented on KAFKA-6683: -- Thanks to you for the response. Sadly I had no luck trying to

[jira] [Comment Edited] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406832#comment-16406832 ] Matthias J. Sax edited comment on KAFKA-6692 at 3/20/18 6:29 PM: - The

[jira] [Commented] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406832#comment-16406832 ] Matthias J. Sax commented on KAFKA-6692: The prefix of those topics is the user specified

[jira] [Commented] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406801#comment-16406801 ] Guozhang Wang commented on KAFKA-6692: -- Maybe this can better be handled in

[jira] [Issue Comment Deleted] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6692: --- Comment: was deleted (was: All internal topics are prefixed with the user specified

[jira] [Comment Edited] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406777#comment-16406777 ] Matthias J. Sax edited comment on KAFKA-6692 at 3/20/18 6:04 PM: - All

[jira] [Comment Edited] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406777#comment-16406777 ] Matthias J. Sax edited comment on KAFKA-6692 at 3/20/18 6:03 PM: - All

[jira] [Comment Edited] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406777#comment-16406777 ] Matthias J. Sax edited comment on KAFKA-6692 at 3/20/18 6:02 PM: - All

[jira] [Comment Edited] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406777#comment-16406777 ] Matthias J. Sax edited comment on KAFKA-6692 at 3/20/18 6:02 PM: - All

[jira] [Commented] (KAFKA-6376) Improve Streams metrics for skipped records

[ https://issues.apache.org/jira/browse/KAFKA-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406785#comment-16406785 ] Guozhang Wang commented on KAFKA-6376: -- Just to summarize places where Streams library could skip

[jira] [Comment Edited] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406777#comment-16406777 ] Matthias J. Sax edited comment on KAFKA-6692 at 3/20/18 6:01 PM: - All

[jira] [Comment Edited] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406777#comment-16406777 ] Matthias J. Sax edited comment on KAFKA-6692 at 3/20/18 6:00 PM: - All

[jira] [Comment Edited] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406777#comment-16406777 ] Matthias J. Sax edited comment on KAFKA-6692 at 3/20/18 5:59 PM: - All

[jira] [Commented] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406777#comment-16406777 ] Matthias J. Sax commented on KAFKA-6692: All internal topics are prefixed with the user specified

[jira] [Updated] (KAFKA-6690) Priorities for Source Topics

[ https://issues.apache.org/jira/browse/KAFKA-6690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6690: --- Component/s: streams > Priorities for Source Topics > > >

[jira] [Updated] (KAFKA-6690) Priorities for Source Topics

[ https://issues.apache.org/jira/browse/KAFKA-6690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6690: --- Issue Type: New Feature (was: Improvement) > Priorities for Source Topics >

[jira] [Comment Edited] (KAFKA-6682) Kafka reconnection after broker restart

[ https://issues.apache.org/jira/browse/KAFKA-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406717#comment-16406717 ] Manikumar edited comment on KAFKA-6682 at 3/20/18 5:14 PM: --- Looks like this

[jira] [Commented] (KAFKA-6682) Kafka reconnection after broker restart

[ https://issues.apache.org/jira/browse/KAFKA-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406717#comment-16406717 ] Manikumar commented on KAFKA-6682: -- Looks like this fixed in :

[jira] [Commented] (KAFKA-6084) ReassignPartitionsCommand should propagate JSON parsing failures

[ https://issues.apache.org/jira/browse/KAFKA-6084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406696#comment-16406696 ] Viktor Somogyi commented on KAFKA-6084: --- [~nickt] it seems the linked PR doesn't fix my general

[jira] [Updated] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

[ https://issues.apache.org/jira/browse/KAFKA-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yeva Byzek updated KAFKA-6692: -- Description: Issue: users cannot quickly/easily differentiate between their explicitly created topics

[jira] [Created] (KAFKA-6692) Kafka Streams internal topics should be prefixed with an underscore

Yeva Byzek created KAFKA-6692: - Summary: Kafka Streams internal topics should be prefixed with an underscore Key: KAFKA-6692 URL: https://issues.apache.org/jira/browse/KAFKA-6692 Project: Kafka

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406681#comment-16406681 ] Narayan Periwal commented on KAFKA-6681: [~tedyu], Attached the server side logs. Could not

[jira] [Commented] (KAFKA-5891) Cast transformation fails if record schema contains timestamp field

[ https://issues.apache.org/jira/browse/KAFKA-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406667#comment-16406667 ] Randall Hauch commented on KAFKA-5891: -- KAFKA-6290 is another issue related to the CAST

[jira] [Updated] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narayan Periwal updated KAFKA-6681: --- Attachment: server-2.log server-1.log > Two instances of kafka consumer

[jira] [Commented] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406470#comment-16406470 ] Amit Sela commented on KAFKA-6684: -- [~hachikuji] mind taking a look? > Support casting values with bytes

[jira] [Commented] (KAFKA-6680) Fix config initialization in DynamicBrokerConfig

[ https://issues.apache.org/jira/browse/KAFKA-6680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406439#comment-16406439 ] ASF GitHub Bot commented on KAFKA-6680: --- rajinisivaram opened a new pull request #4740: MINOR:

[jira] [Created] (KAFKA-6691) Requesting High Watermark and Truncation documentation be added to Docs

Justin Manchester created KAFKA-6691: Summary: Requesting High Watermark and Truncation documentation be added to Docs Key: KAFKA-6691 URL: https://issues.apache.org/jira/browse/KAFKA-6691

[jira] [Updated] (KAFKA-6690) Priorities for Source Topics

[ https://issues.apache.org/jira/browse/KAFKA-6690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bala Prassanna I updated KAFKA-6690: Description: We often encounter use cases where we need to prioritise source topics. If a

[jira] [Updated] (KAFKA-6690) Priorities for Source Topics

[ https://issues.apache.org/jira/browse/KAFKA-6690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bala Prassanna I updated KAFKA-6690: Description: We often encounter use cases where we need to prioritise source topics. If a

[jira] [Created] (KAFKA-6690) Priorities for Source Topics

Bala Prassanna I created KAFKA-6690: --- Summary: Priorities for Source Topics Key: KAFKA-6690 URL: https://issues.apache.org/jira/browse/KAFKA-6690 Project: Kafka Issue Type: Improvement

[jira] [Comment Edited] (KAFKA-6685) Connect deserialization log message should distinguish key from value

[ https://issues.apache.org/jira/browse/KAFKA-6685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406081#comment-16406081 ] Jagadesh Adireddi edited comment on KAFKA-6685 at 3/20/18 10:25 AM: Hi

[jira] [Resolved] (KAFKA-6613) The controller shouldn't stop partition reassignment after an exception is being thrown

[ https://issues.apache.org/jira/browse/KAFKA-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chandra kasiraju resolved KAFKA-6613. - Resolution: Fixed Fix Version/s: (was: 0.11.0.2) 1.0.0 >

[jira] [Commented] (KAFKA-6613) The controller shouldn't stop partition reassignment after an exception is being thrown

[ https://issues.apache.org/jira/browse/KAFKA-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16405915#comment-16405915 ] chandra kasiraju commented on KAFKA-6613: - thanks [~omkreddy] i will try 1.0 and see if that is

[jira] [Comment Edited] (KAFKA-6689) Kafka not release .deleted file.

[ https://issues.apache.org/jira/browse/KAFKA-6689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16405870#comment-16405870 ] Manikumar edited comment on KAFKA-6689 at 3/20/18 7:05 AM: --- These temp files

[jira] [Commented] (KAFKA-6689) Kafka not release .deleted file.

[ https://issues.apache.org/jira/browse/KAFKA-6689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16405892#comment-16405892 ] A commented on KAFKA-6689: -- This parameter affect on broker1 (it cleaning temp file normally)  But on the

[jira] [Commented] (KAFKA-6689) Kafka not release .deleted file.

[ https://issues.apache.org/jira/browse/KAFKA-6689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16405870#comment-16405870 ] Manikumar commented on KAFKA-6689: -- There temp files will be deleted after file.delete.delay.ms (default: