[jira] [Commented] (KAFKA-6881) Kafka 1.1 Broker version crashes when deleting log

[ https://issues.apache.org/jira/browse/KAFKA-6881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476940#comment-16476940 ] K B Parthasarathy commented on KAFKA-6881: -- Thanks for the reply. We changed the

[jira] [Commented] (KAFKA-6881) Kafka 1.1 Broker version crashes when deleting log

[ https://issues.apache.org/jira/browse/KAFKA-6881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476859#comment-16476859 ] Arun Yadav commented on KAFKA-6881: --- As [~omkreddy] and [~ijuma] suggested, the files un

[jira] [Commented] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476832#comment-16476832 ] Matthias J. Sax commented on KAFKA-6906: Thinking about this twice, I am wondering

[jira] [Commented] (KAFKA-6905) Document that Processor objects can be reused

[ https://issues.apache.org/jira/browse/KAFKA-6905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476830#comment-16476830 ] Matthias J. Sax commented on KAFKA-6905: You would edit the file in `kafka` reposi

[jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476791#comment-16476791 ] Gaurav Nanda commented on KAFKA-3410: - We faced this issue today, broker 1,2,3 were ru

[jira] [Commented] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations

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

[jira] [Assigned] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

[ https://issues.apache.org/jira/browse/KAFKA-6906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadesh Adireddi reassigned KAFKA-6906: Assignee: Jagadesh Adireddi > Kafka Streams does not commit transactions if data is

[jira] [Assigned] (KAFKA-4453) add request prioritization

[ https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang reassigned KAFKA-4453: - Assignee: Lucas Wang (was: Onur Karaman) > add request prioritization >

[jira] [Created] (KAFKA-6906) Kafka Streams does not commit transactions if data is produced via wall-clock punctuation

Matthias J. Sax created KAFKA-6906: -- Summary: Kafka Streams does not commit transactions if data is produced via wall-clock punctuation Key: KAFKA-6906 URL: https://issues.apache.org/jira/browse/KAFKA-6906

[jira] [Updated] (KAFKA-4936) Allow dynamic routing of output records

[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4936: --- Labels: kip (was: needs-kip) > Allow dynamic routing of output records >

[jira] [Updated] (KAFKA-4936) Allow dynamic routing of output records

[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4936: --- Description: Currently, all used output topics must be know beforehand, and thus, it's not po

[jira] [Updated] (KAFKA-4936) Allow dynamic routing of output records

[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4936: --- Fix Version/s: 2.0.0 > Allow dynamic routing of output records > -

[jira] [Commented] (KAFKA-6905) Document that Processor objects can be reused

[ https://issues.apache.org/jira/browse/KAFKA-6905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476522#comment-16476522 ] David Glasser commented on KAFKA-6905: -- Thanks Matthias. I'm a little confused about

[jira] [Commented] (KAFKA-6864) null is not passed to keyDeserialzer and valueDeserializer in Fetcher

[ https://issues.apache.org/jira/browse/KAFKA-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476519#comment-16476519 ] Guozhang Wang commented on KAFKA-6864: -- I'd like [~hachikuji] to chime in here as it

[jira] [Updated] (KAFKA-6896) add producer metrics exporting in KafkaStreams.java

[ https://issues.apache.org/jira/browse/KAFKA-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6896: - Fix Version/s: 2.0.0 > add producer metrics exporting in KafkaStreams.java > -

[jira] [Commented] (KAFKA-6896) add producer metrics exporting in KafkaStreams.java

[ https://issues.apache.org/jira/browse/KAFKA-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476497#comment-16476497 ] ASF GitHub Bot commented on KAFKA-6896: --- guozhangwang closed pull request #4998: KAF

[jira] [Resolved] (KAFKA-6896) add producer metrics exporting in KafkaStreams.java

[ https://issues.apache.org/jira/browse/KAFKA-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6896. -- Resolution: Fixed > add producer metrics exporting in KafkaStreams.java > --

[jira] [Commented] (KAFKA-6905) Document that Processor objects can be reused

[ https://issues.apache.org/jira/browse/KAFKA-6905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476469#comment-16476469 ] Matthias J. Sax commented on KAFKA-6905: Thanks for reporting the issues – the beh

[jira] [Commented] (KAFKA-6864) null is not passed to keyDeserialzer and valueDeserializer in Fetcher

[ https://issues.apache.org/jira/browse/KAFKA-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476464#comment-16476464 ] Matthias J. Sax commented on KAFKA-6864: Do you use log-compaction for those topic

[jira] [Updated] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6657: --- Fix Version/s: 2.0.0 > Add StreamsConfig prefix for different consumers >

[jira] [Commented] (KAFKA-6905) Document that Processor objects can be reused

[ https://issues.apache.org/jira/browse/KAFKA-6905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476447#comment-16476447 ] John Roesler commented on KAFKA-6905: - Thanks for the report, [~glasser], Can you pro

[jira] [Commented] (KAFKA-6123) Give client MetricsReporter auto-generated client.id

[ https://issues.apache.org/jira/browse/KAFKA-6123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476361#comment-16476361 ] ASF GitHub Bot commented on KAFKA-6123: --- KevinLiLu closed pull request #4637: KAFKA-

[jira] [Commented] (KAFKA-6841) Add support for wildcard suffixed ACLs

[ https://issues.apache.org/jira/browse/KAFKA-6841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476355#comment-16476355 ] Rajini Sivaram commented on KAFKA-6841: --- [~piyushvijay] Since we don't normally back

[jira] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476341#comment-16476341 ] Marcus Portmann commented on KAFKA-4740: Is the intention still to return the part

[jira] [Created] (KAFKA-6905) Document that Processor objects can be reused

David Glasser created KAFKA-6905: Summary: Document that Processor objects can be reused Key: KAFKA-6905 URL: https://issues.apache.org/jira/browse/KAFKA-6905 Project: Kafka Issue Type: Impro

[jira] [Assigned] (KAFKA-6729) KTable should use user source topics if possible and not create changelog topic

[ https://issues.apache.org/jira/browse/KAFKA-6729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6729: -- Assignee: Guozhang Wang (was: Bill Bejeck) > KTable should use user source topics if p

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

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

[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=16476237#comment-16476237 ] Randall Hauch commented on KAFKA-3821: -- Hi, Gunnar. Trying to get back to this to see

[jira] [Comment Edited] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476100#comment-16476100 ] Ted Yu edited comment on KAFKA-6188 at 5/15/18 5:14 PM: >From the

[jira] [Commented] (KAFKA-6864) null is not passed to keyDeserialzer and valueDeserializer in Fetcher

[ https://issues.apache.org/jira/browse/KAFKA-6864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476203#comment-16476203 ] Mathias Kub commented on KAFKA-6864: [~mjsax] Thanks for your reply. Yes, it is. We a

[jira] [Updated] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna updated KAFKA-6188: Attachment: output.txt > Broker fails with FATAL Shutdown - log dirs have failed > -

[jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476100#comment-16476100 ] Ted Yu commented on KAFKA-6188: --- >From the stack trace Manna provided, it seems we can catch

[jira] [Comment Edited] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476061#comment-16476061 ] M. Manna edited comment on KAFKA-6188 at 5/15/18 4:01 PM: -- [~Teil

[jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476061#comment-16476061 ] M. Manna commented on KAFKA-6188: - [~TeilaRei] and [~darion] I am not sure if this version

[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=16476054#comment-16476054 ] Amit Sela commented on KAFKA-6684: -- [~ewencp] any updates on this? > Support casting val

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476020#comment-16476020 ] Attila Sasvari commented on KAFKA-6884: --- - tests that verify timeouts pass after mak

[jira] [Comment Edited] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16475872#comment-16475872 ] Valentina Baljak edited comment on KAFKA-6188 at 5/15/18 1:56 PM: --

[jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16475872#comment-16475872 ] Valentina Baljak commented on KAFKA-6188: - Darion Yaphet, that is very interesting

[jira] [Assigned] (KAFKA-6644) Make Server Info more generic for Kafka Interactive Queries

[ https://issues.apache.org/jira/browse/KAFKA-6644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raja Guru Thirumavalavan reassigned KAFKA-6644: --- Assignee: Raja Guru Thirumavalavan > Make Server Info more generic fo

[jira] [Commented] (KAFKA-6077) Let SimpleConsumer support Kerberos authentication

[ https://issues.apache.org/jira/browse/KAFKA-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16475771#comment-16475771 ] Aniket Alhat commented on KAFKA-6077: - Hello [~huangjianan] I'm facing a similar probl

[jira] [Commented] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16475751#comment-16475751 ] Attila Sasvari commented on KAFKA-6884: --- Thanks [~hachikuji]. I have seen the pull r

[jira] [Commented] (KAFKA-6902) During replica reassignment if source broker is down the partition directory may not be removed from broker log.dirs

[ https://issues.apache.org/jira/browse/KAFKA-6902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16475642#comment-16475642 ] Hugh O'Brien commented on KAFKA-6902: - It would also be useful for the broker to highl