[jira] [Created] (KAFKA-5984) API changes review for Kafka

2017-09-27 Thread Andrey Ponomarenko (JIRA)
Andrey Ponomarenko created KAFKA-5984: - Summary: API changes review for Kafka Key: KAFKA-5984 URL: https://issues.apache.org/jira/browse/KAFKA-5984 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-5867) Kafka Connect applications should log info message when starting up

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183671#comment-16183671 ] ASF GitHub Bot commented on KAFKA-5867: --- Github user asfgit closed the pull request

[jira] [Comment Edited] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

2017-09-27 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183580#comment-16183580 ] Richard Yu edited comment on KAFKA-4499 at 9/28/17 3:45 AM: [~

[jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

2017-09-27 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183580#comment-16183580 ] Richard Yu commented on KAFKA-4499: --- [~mjsax] If this is not the right way, then please

[jira] [Issue Comment Deleted] (KAFKA-903) [0.8.0 - windows] FATAL - [highwatermark-checkpoint-thread1] (Logging.scala:109) - Attempt to swap the new high watermark file with the old one failed

2017-09-27 Thread Sean Glover (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Glover updated KAFKA-903: -- Comment: was deleted (was: I still see this exception on Windows 7 Pro SP1 with kafka 0.8.0 beta 1. [201

[jira] [Updated] (KAFKA-5913) Add `hasOffset` and `hasTimestamp` methods to RecordMetadata to indicate whether metadata is available

2017-09-27 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5913: Description: One of the changes in KIP-192 is to send a {{DUPLICATE_SEQUENCE}} error code with a {{

[jira] [Updated] (KAFKA-5913) Add `hasOffset` and `hasTimestamp` methods to RecordMetadata to indicate whether metadata is available

2017-09-27 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5913: Summary: Add `hasOffset` and `hasTimestamp` methods to RecordMetadata to indicate whether metadata i

[jira] [Commented] (KAFKA-5979) kip-120 changed internal streams topic naming

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183488#comment-16183488 ] ASF GitHub Bot commented on KAFKA-5979: --- GitHub user mjsax opened a pull request:

[jira] [Updated] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

2017-09-27 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5473: --- Fix Version/s: 1.0.1 > handle ZK session expiration properly when a new session can't be established >

[jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

2017-09-27 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183429#comment-16183429 ] Ismael Juma commented on KAFKA-5473: [~prasincs], are you planning to submit a PR for

[jira] [Commented] (KAFKA-5225) StreamsResetter doesn't allow custom Consumer properties

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183265#comment-16183265 ] ASF GitHub Bot commented on KAFKA-5225: --- Github user bharatviswa504 closed the pull

[jira] [Commented] (KAFKA-5932) Avoid call fetchPrevious in FlushListeners

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183203#comment-16183203 ] ASF GitHub Bot commented on KAFKA-5932: --- GitHub user bbejeck opened a pull request:

[jira] [Commented] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

2017-09-27 Thread Peter Davis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183129#comment-16183129 ] Peter Davis commented on KAFKA-5970: In our case, turns out there's a very chatty cons

[jira] [Commented] (KAFKA-5960) Producer uses unsupported ProduceRequest version against older brokers

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182999#comment-16182999 ] ASF GitHub Bot commented on KAFKA-5960: --- GitHub user hachikuji opened a pull request

[jira] [Resolved] (KAFKA-5369) Producer hangs on metadata fetch from broker in security authorization related failures and no meaningful exception is thrown

2017-09-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5369. -- Resolution: Duplicate Resolving this as duplicate of KAFKA-4764, KAFKA-5920 > Producer hangs on metad

[jira] [Assigned] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper

2017-09-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-4914: Assignee: (was: Manikumar) > Partition re-assignment tool should check types before persisting

[jira] [Assigned] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper

2017-09-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-4914: Assignee: Manikumar > Partition re-assignment tool should check types before persisting state in >

[jira] [Updated] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper

2017-09-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-4914: - Priority: Major (was: Minor) > Partition re-assignment tool should check types before persisting state in

[jira] [Commented] (KAFKA-5982) Kafka 0.9.0.1 doesn't start after delete storage dir

2017-09-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182969#comment-16182969 ] Manikumar commented on KAFKA-5982: -- Please check KAFKA-5917 > Kafka 0.9.0.1 doesn't sta

[jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182962#comment-16182962 ] ASF GitHub Bot commented on KAFKA-5973: --- Github user tedyu closed the pull request a

[jira] [Commented] (KAFKA-5902) Create Connect metrics for sink tasks

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182960#comment-16182960 ] ASF GitHub Bot commented on KAFKA-5902: --- GitHub user rhauch opened a pull request:

[jira] [Commented] (KAFKA-5597) Autogenerate Producer sender metrics

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182884#comment-16182884 ] ASF GitHub Bot commented on KAFKA-5597: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-09-27 Thread Roger Hoover (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182867#comment-16182867 ] Roger Hoover commented on KAFKA-5973: - [~ijuma] Great points. A stable metric solves t

[jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-09-27 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182856#comment-16182856 ] Ismael Juma commented on KAFKA-5973: A few things to think about before we devise a so

[jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-09-27 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182839#comment-16182839 ] Ismael Juma commented on KAFKA-5973: [~theduderog], hmm, I don't understand why. If th

[jira] [Comment Edited] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-09-27 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182839#comment-16182839 ] Ismael Juma edited comment on KAFKA-5973 at 9/27/17 4:25 PM: -

[jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-09-27 Thread Roger Hoover (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182794#comment-16182794 ] Roger Hoover commented on KAFKA-5973: - [~ijuma] You're right that failing more aggres

[jira] [Commented] (KAFKA-4632) Kafka Connect WorkerSinkTask.closePartitions doesn't handle WakeupException

2017-09-27 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182785#comment-16182785 ] Randall Hauch commented on KAFKA-4632: -- Actually, it looks like at least as far back

[jira] [Commented] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

2017-09-27 Thread Scott Reynolds (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182779#comment-16182779 ] Scott Reynolds commented on KAFKA-5970: --- Ran into a very similar deadlock {code} Fo

[jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-09-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182775#comment-16182775 ] Ted Yu commented on KAFKA-5973: --- [~ijuma]: Among the threads identified by Tom, can you see

[jira] [Commented] (KAFKA-4632) Kafka Connect WorkerSinkTask.closePartitions doesn't handle WakeupException

2017-09-27 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182770#comment-16182770 ] Randall Hauch commented on KAFKA-4632: -- [~ScottReynolds], thanks for reporting this.

[jira] [Assigned] (KAFKA-5445) Document exceptions thrown by AdminClient methods

2017-09-27 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-5445: -- Assignee: Andrey Dyachkov (was: Colin P. McCabe) > Document exceptions thrown by AdminClient m

[jira] [Assigned] (KAFKA-5950) AdminClient should retry based on returned error codes

2017-09-27 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-5950: -- Assignee: Andrey Dyachkov > AdminClient should retry based on returned error codes > --

[jira] [Updated] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-09-27 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5973: --- Fix Version/s: (was: 1.0.0) 1.0.1 > ShutdownableThread catching errors can lead

[jira] [Updated] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-09-27 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5973: --- Priority: Major (was: Minor) > ShutdownableThread catching errors can lead to partial hard to diagnos

[jira] [Commented] (KAFKA-5750) Elevate log messages for denials to INFO in SimpleAclAuthorizer class

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182750#comment-16182750 ] ASF GitHub Bot commented on KAFKA-5750: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-09-27 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182705#comment-16182705 ] Ismael Juma commented on KAFKA-5973: Because of the statefulness of Kafka brokers, you

[jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-09-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182694#comment-16182694 ] Ted Yu commented on KAFKA-5973: --- [~damianguy] [~guozhang]: Can you take a look ? Thanks >

[jira] [Created] (KAFKA-5983) Cannot mirror Avro-encoded data using the Apache Kafka MirrorMaker

2017-09-27 Thread Giulio Vito de Musso (JIRA)
Giulio Vito de Musso created KAFKA-5983: --- Summary: Cannot mirror Avro-encoded data using the Apache Kafka MirrorMaker Key: KAFKA-5983 URL: https://issues.apache.org/jira/browse/KAFKA-5983 Projec

[jira] [Updated] (KAFKA-5982) Kafka 0.9.0.1 doesn't start after delete storage dir

2017-09-27 Thread Marc Cortinas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marc Cortinas updated KAFKA-5982: - Description: Hi, My environment I has 3 zoo and 3 kafka brokers. The issue appear after restart

[jira] [Updated] (KAFKA-5982) Kafka 0.9.0.1 doesn't start after delete storage dir

2017-09-27 Thread Marc Cortinas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marc Cortinas updated KAFKA-5982: - Attachment: broker-083u1.tar.gz broker-084u1.tar.gz broker-084u3.ta

[jira] [Updated] (KAFKA-5982) Kafka 0.9.0.1 doesn't start after delete storage dir

2017-09-27 Thread Marc Cortinas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marc Cortinas updated KAFKA-5982: - Description: Hi, My environment I has 3 zoo and 3 kafka brokers. The issue appear after restart

[jira] [Created] (KAFKA-5982) Kafka 0.9.0.1 doesn't start after delete storage dir

2017-09-27 Thread Marc Cortinas (JIRA)
Marc Cortinas created KAFKA-5982: Summary: Kafka 0.9.0.1 doesn't start after delete storage dir Key: KAFKA-5982 URL: https://issues.apache.org/jira/browse/KAFKA-5982 Project: Kafka Issue Type

[jira] [Created] (KAFKA-5981) Update the affected versions on bug KAFKA-1194

2017-09-27 Thread JIRA
Amund Gjersøe created KAFKA-5981: Summary: Update the affected versions on bug KAFKA-1194 Key: KAFKA-5981 URL: https://issues.apache.org/jira/browse/KAFKA-5981 Project: Kafka Issue Type: Sub-