[jira] [Comment Edited] (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&focusedCommentId=16404435#comment-16404435 ] Gunnar Morling edited comment on KAFKA-3821 at 3/19/18 7:07 AM:

[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&focusedCommentId=16404435#comment-16404435 ] Gunnar Morling commented on KAFKA-3821: --- Hey [~rhauch], another alternative API cros

[jira] [Commented] (KAFKA-6659) Improve error message if state store is not found

[ https://issues.apache.org/jira/browse/KAFKA-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404449#comment-16404449 ] Stuart Perks commented on KAFKA-6659: - Thanks. Aiming get PR in tonight. Do not seem t

[jira] [Commented] (KAFKA-6659) Improve error message if state store is not found

[ https://issues.apache.org/jira/browse/KAFKA-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404467#comment-16404467 ] ASF GitHub Bot commented on KAFKA-6659: --- perkss opened a new pull request #4732: KAF

[jira] [Commented] (KAFKA-6582) Partitions get underreplicated, with a single ISR, and doesn't recover. Other brokers do not take over and we need to manually restart the broker.

[ https://issues.apache.org/jira/browse/KAFKA-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404550#comment-16404550 ] Chetan Pandey commented on KAFKA-6582: -- I am facing the same issue while upgrading ou

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404608#comment-16404608 ] Jurriaan Pruis commented on KAFKA-4477: --- We have a similar issue on Kafka 1.0.0, See

[jira] [Commented] (KAFKA-6676) System tests do not handle ZK chroot properly with SCRAM

[ https://issues.apache.org/jira/browse/KAFKA-6676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404613#comment-16404613 ] ASF GitHub Bot commented on KAFKA-6676: --- rajinisivaram closed pull request #4729: KA

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

Manikumar created KAFKA-6680: Summary: Fix config initialization in DynamicBrokerConfig Key: KAFKA-6680 URL: https://issues.apache.org/jira/browse/KAFKA-6680 Project: Kafka Issue Type: Bug

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

Narayan Periwal created KAFKA-6681: -- Summary: Two instances of kafka consumer reading the same partition within a consumer group Key: KAFKA-6681 URL: https://issues.apache.org/jira/browse/KAFKA-6681

[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: --- Description: We have seen this issue with the Kafka consumer, the new library that got introd

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

Tomasz Gąska created KAFKA-6682: --- Summary: Kafka reconnection after broker restart Key: KAFKA-6682 URL: https://issues.apache.org/jira/browse/KAFKA-6682 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404947#comment-16404947 ] Jagadesh Adireddi commented on KAFKA-6629: -- Hi [~guozhang], I am new to kafka con

[jira] [Comment Edited] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404947#comment-16404947 ] Jagadesh Adireddi edited comment on KAFKA-6629 at 3/19/18 3:36 PM: -

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

Chema Sanchez created KAFKA-6683: Summary: ReplicaFetcher crashes with "Attempted to complete a transaction which was not started" Key: KAFKA-6683 URL: https://issues.apache.org/jira/browse/KAFKA-6683

[jira] [Updated] (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:all-tabpanel ] Chema Sanchez updated KAFKA-6683: - Description: We have been experiencing this issue lately when restarting or replacing brokers of

[jira] [Updated] (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:all-tabpanel ] Chema Sanchez updated KAFKA-6683: - Description: We have been experiencing this issue lately when restarting or replacing brokers of

[jira] [Updated] (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:all-tabpanel ] Chema Sanchez updated KAFKA-6683: - Description: We have been experiencing this issue lately when restarting or replacing brokers of

[jira] [Commented] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404999#comment-16404999 ] Ari Uka commented on KAFKA-6679: When I run `/usr/local/share/kafka_2.12-1.0.1/bin/kafka-r

[jira] [Assigned] (KAFKA-6659) Improve error message if state store is not found

[ https://issues.apache.org/jira/browse/KAFKA-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-6659: Assignee: Stuart Perks > Improve error message if state store is not found > --

[jira] [Commented] (KAFKA-6659) Improve error message if state store is not found

[ https://issues.apache.org/jira/browse/KAFKA-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405007#comment-16405007 ] Guozhang Wang commented on KAFKA-6659: -- Hi Stuart, I have added you to the contributo

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

[ https://issues.apache.org/jira/browse/KAFKA-6680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-6680: Assignee: Manikumar Fix Version/s: 1.2.0 PR: https://github.com/apache/kafka/pull/4731 >

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

Yeva Byzek created KAFKA-6685: - Summary: Connect deserialization log message should distinguish key from value Key: KAFKA-6685 URL: https://issues.apache.org/jira/browse/KAFKA-6685 Project: Kafka

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

Amit Sela created KAFKA-6684: Summary: Support casting values with bytes schema to string Key: KAFKA-6684 URL: https://issues.apache.org/jira/browse/KAFKA-6684 Project: Kafka Issue Type: Improve

[jira] [Updated] (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:all-tabpanel ] Amit Sela updated KAFKA-6684: - Reviewer: (was: Jason Gustafson) > Support casting values with bytes schema to string > ---

[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&focusedCommentId=16405015#comment-16405015 ] Amit Sela commented on KAFKA-6684: -- I have a working branch, but I wanted to get some fee

[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&focusedCommentId=16405043#comment-16405043 ] Randall Hauch commented on KAFKA-6685: -- The stack trace often looks something like:

[jira] [Updated] (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:all-tabpanel ] Randall Hauch updated KAFKA-6685: - Labels: newbie (was: ) > Connect deserialization log message should distinguish key from value >

[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&focusedCommentId=16405059#comment-16405059 ] Randall Hauch commented on KAFKA-3821: -- Thanks, [~gunnar.morling]. I do tend to favor

[jira] [Created] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable

Matthias J. Sax created KAFKA-6686: -- Summary: Allow reading topic as KStream and GlobalKTable Key: KAFKA-6686 URL: https://issues.apache.org/jira/browse/KAFKA-6686 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-6686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6686: --- Description: Users often want to read topic multiple times, eg, as a stream and a table. For

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

Matthias J. Sax created KAFKA-6687: -- Summary: Allow to read a topic multiple times Key: KAFKA-6687 URL: https://issues.apache.org/jira/browse/KAFKA-6687 Project: Kafka Issue Type: Improvemen

[jira] [Commented] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405120#comment-16405120 ] Guozhang Wang commented on KAFKA-6629: -- Hello Jagadesh, In SegmentedCacheFunctionTes

[jira] [Commented] (KAFKA-6659) Improve error message if state store is not found

[ https://issues.apache.org/jira/browse/KAFKA-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405173#comment-16405173 ] Stuart Perks commented on KAFKA-6659: - Thanks Guozhang > Improve error message if sta

[jira] [Commented] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405191#comment-16405191 ] Jagadesh Adireddi commented on KAFKA-6629: -- Hi Guozhang Thank you  for the info

[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&focusedCommentId=16405332#comment-16405332 ] Jason Gustafson commented on KAFKA-6683: Thanks for the report. I tried reproducin

[jira] [Assigned] (KAFKA-3365) Add a documentation field for types and update doc generation

[ https://issues.apache.org/jira/browse/KAFKA-3365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Beni reassigned KAFKA-3365: -- Assignee: Andras Beni > Add a documentation field for types and update doc generation > ---

[jira] [Commented] (KAFKA-3365) Add a documentation field for types and update doc generation

[ https://issues.apache.org/jira/browse/KAFKA-3365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405375#comment-16405375 ] ASF GitHub Bot commented on KAFKA-3365: --- andrasbeni opened a new pull request #4735:

[jira] [Commented] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405478#comment-16405478 ] Ari Uka commented on KAFKA-6679: So the records seem to be v2, in this case, there were 5

[jira] [Comment Edited] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405478#comment-16405478 ] Ari Uka edited comment on KAFKA-6679 at 3/19/18 9:25 PM: - So the r

[jira] [Comment Edited] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405478#comment-16405478 ] Ari Uka edited comment on KAFKA-6679 at 3/19/18 9:26 PM: - So the r

[jira] [Comment Edited] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405478#comment-16405478 ] Ari Uka edited comment on KAFKA-6679 at 3/19/18 9:27 PM: - So the r

[jira] [Comment Edited] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405478#comment-16405478 ] Ari Uka edited comment on KAFKA-6679 at 3/19/18 10:12 PM: -- So the

[jira] [Commented] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405538#comment-16405538 ] Ismael Juma commented on KAFKA-6679: I wasn't too clear how the corrupted data was pro

[jira] [Commented] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405539#comment-16405539 ] Ari Uka commented on KAFKA-6679: We have been using [https://github.com/Shopify/sarama], s

[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&focusedCommentId=16405544#comment-16405544 ] ASF GitHub Bot commented on KAFKA-6680: --- rajinisivaram closed pull request #4731: K

[jira] [Commented] (KAFKA-6679) Random corruption (CRC validation issues)

[ https://issues.apache.org/jira/browse/KAFKA-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405548#comment-16405548 ] Ismael Juma commented on KAFKA-6679: The broker performs some verification, but it is

[jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length

[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405553#comment-16405553 ] James Cheng commented on KAFKA-4893: We just ran into this. Our mirroring setup automa

[jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length

[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405558#comment-16405558 ] James Cheng commented on KAFKA-4893: We ran into another error which may be related to

[jira] [Resolved] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

[ https://issues.apache.org/jira/browse/KAFKA-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-6661. -- Resolution: Fixed > Sink connectors that explicitly 'resume' topic partitions can resume a pause

[jira] [Commented] (KAFKA-6240) Support dynamic updates of frequently updated broker configs

[ https://issues.apache.org/jira/browse/KAFKA-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405597#comment-16405597 ] Brett Rann commented on KAFKA-6240: --- If you've come here from release notes looking for

[jira] [Commented] (KAFKA-6473) Add MockProcessorContext to public test-utils

[ https://issues.apache.org/jira/browse/KAFKA-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405638#comment-16405638 ] ASF GitHub Bot commented on KAFKA-6473: --- vvcephei opened a new pull request #4736: K

[jira] [Comment Edited] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get()

[ https://issues.apache.org/jira/browse/KAFKA-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302643#comment-16302643 ] Ted Yu edited comment on KAFKA-5802 at 3/20/18 1:02 AM: +1 from me

[jira] [Created] (KAFKA-6688) The Trogdor coordinator should track task statuses

Colin P. McCabe created KAFKA-6688: -- Summary: The Trogdor coordinator should track task statuses Key: KAFKA-6688 URL: https://issues.apache.org/jira/browse/KAFKA-6688 Project: Kafka Issue Ty

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

A created KAFKA-6689: Summary: Kafka not release .deleted file. Key: KAFKA-6689 URL: https://issues.apache.org/jira/browse/KAFKA-6689 Project: Kafka Issue Type: Bug Components: config, controll

[jira] [Commented] (KAFKA-6688) The Trogdor coordinator should track task statuses

[ https://issues.apache.org/jira/browse/KAFKA-6688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405820#comment-16405820 ] ASF GitHub Bot commented on KAFKA-6688: --- cmccabe opened a new pull request #4737: KA

[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&focusedCommentId=16405870#comment-16405870 ] Manikumar commented on KAFKA-6689: -- There temp files will be deleted after file.delete.de