[jira] [Created] (KAFKA-6041) "--producer.config" option doesn't work

2017-10-10 Thread Phoenix_Dad (JIRA)
Phoenix_Dad created KAFKA-6041: -- Summary: "--producer.config" option doesn't work Key: KAFKA-6041 URL: https://issues.apache.org/jira/browse/KAFKA-6041 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-3359) Parallel log-recovery of un-flushed segments on startup

2017-10-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198493#comment-16198493 ] Ismael Juma commented on KAFKA-3359: [~bobrik], it shouldn't read all data from the partition. You may

[jira] [Assigned] (KAFKA-6027) System test failure: LogDirFailureTest

2017-10-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-6027: -- Assignee: Dong Lin https://github.com/apache/kafka/pull/4045 > System test failure:

[jira] [Commented] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198505#comment-16198505 ] Ismael Juma commented on KAFKA-6042: [~corlettb], you could create a build from the 0.11.0 branch as

[jira] [Commented] (KAFKA-6027) System test failure: LogDirFailureTest

2017-10-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198508#comment-16198508 ] Dong Lin commented on KAFKA-6027: - [~ijuma] Yeah it is really convenient to setup system test using

[jira] [Created] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-10 Thread Ben Corlett (JIRA)
Ben Corlett created KAFKA-6042: -- Summary: Kafka Request Handler deadlocks and brings down the cluster. Key: KAFKA-6042 URL: https://issues.apache.org/jira/browse/KAFKA-6042 Project: Kafka

[jira] [Commented] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198453#comment-16198453 ] Manikumar commented on KAFKA-6042: -- This may be related KAFKA-5970 > Kafka Request Handler deadlocks and

[jira] [Commented] (KAFKA-4029) SSL support for Connect REST API

2017-10-10 Thread Jakub Scholz (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198318#comment-16198318 ] Jakub Scholz commented on KAFKA-4029: - Authorization / ACLs would be of course another valuable

[jira] [Commented] (KAFKA-6013) Controller getting stuck

2017-10-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198489#comment-16198489 ] Ismael Juma commented on KAFKA-6013: cc [~onurkaraman] [~junrao] > Controller getting stuck >

[jira] [Commented] (KAFKA-6022) mirror maker stores offset in zookeeper

2017-10-10 Thread Ronald van de Kuil (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198377#comment-16198377 ] Ronald van de Kuil commented on KAFKA-6022: --- Hi Manikumar, I believe that I have found a little

[jira] [Commented] (KAFKA-6040) Expose topic size for monitoring

2017-10-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198397#comment-16198397 ] Ismael Juma commented on KAFKA-6040: Retention is done on a partition, not topic, so the broker

[jira] [Updated] (KAFKA-6013) Controller getting stuck

2017-10-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6013: --- Labels: reliability (was: ) > Controller getting stuck > > >

[jira] [Commented] (KAFKA-6041) "--producer.config" option doesn't work

2017-10-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198392#comment-16198392 ] ASF GitHub Bot commented on KAFKA-6041: --- GitHub user wujianping10043419 opened a pull request:

[jira] [Commented] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-10 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198483#comment-16198483 ] Ben Corlett commented on KAFKA-6042: The second stack trace in that issue looks very familiar. You may

[jira] [Commented] (KAFKA-6022) mirror maker stores offset in zookeeper

2017-10-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198416#comment-16198416 ] Manikumar commented on KAFKA-6022: -- Since 0.10.1.0, no need to pass --new-consumer option. You just need

[jira] [Commented] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198497#comment-16198497 ] Manikumar commented on KAFKA-6042: -- It would we great if you can use KAFKA-5970 and validate in your

[jira] [Created] (KAFKA-6040) Expose topic size for monitoring

2017-10-10 Thread Michael Andre Pearce (JIRA)
Michael Andre Pearce created KAFKA-6040: --- Summary: Expose topic size for monitoring Key: KAFKA-6040 URL: https://issues.apache.org/jira/browse/KAFKA-6040 Project: Kafka Issue Type: New

[jira] [Commented] (KAFKA-6021) run kafka-mirror-maker.sh in daemon mode

2017-10-10 Thread Ronald van de Kuil (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198384#comment-16198384 ] Ronald van de Kuil commented on KAFKA-6021: --- Liie a NOOB I now run it in screen ;) > run

[jira] [Created] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

2017-10-10 Thread Ramkumar (JIRA)
Ramkumar created KAFKA-6043: --- Summary: Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked Key: KAFKA-6043 URL: https://issues.apache.org/jira/browse/KAFKA-6043

[jira] [Commented] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

2017-10-10 Thread Ben Corlett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198640#comment-16198640 ] Ben Corlett commented on KAFKA-6042: I've deployed a build of 0.11.0.1 with the commits of pull

[jira] [Created] (KAFKA-6044) Unable to start broker after ungraceful shutdown on windows

2017-10-10 Thread Niels Hoogeveen (JIRA)
Niels Hoogeveen created KAFKA-6044: -- Summary: Unable to start broker after ungraceful shutdown on windows Key: KAFKA-6044 URL: https://issues.apache.org/jira/browse/KAFKA-6044 Project: Kafka

[jira] [Created] (KAFKA-6045) All access to log should fail if log is closed

2017-10-10 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-6045: --- Summary: All access to log should fail if log is closed Key: KAFKA-6045 URL: https://issues.apache.org/jira/browse/KAFKA-6045 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6046) DeleteRecordsRequest to a non-leader

2017-10-10 Thread Tom Bentley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198963#comment-16198963 ] Tom Bentley commented on KAFKA-6046: It _would be_ covered if execution ever got this far. In fact

[jira] [Updated] (KAFKA-6031) Expose standby replicas endpoints in StreamsMetadata

2017-10-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6031: --- Labels: needs-kip (was: ) > Expose standby replicas endpoints in StreamsMetadata >

[jira] [Commented] (KAFKA-6013) Controller getting stuck

2017-10-10 Thread Ivan Babrou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199121#comment-16199121 ] Ivan Babrou commented on KAFKA-6013: I forced preferred leader election and current controller

[jira] [Commented] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

2017-10-10 Thread Ramkumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198967#comment-16198967 ] Ramkumar commented on KAFKA-6043: - Thanks you for your reply, we found this issue in production in high

[jira] [Commented] (KAFKA-6016) Use the idempotent producer in the reassign_partitions_test

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

[jira] [Commented] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped

2017-10-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199106#comment-16199106 ] Matthias J. Sax commented on KAFKA-3758: > I am running the streams instances on the same machines

[jira] [Commented] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

2017-10-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198944#comment-16198944 ] Ted Yu commented on KAFKA-6043: --- 0.8.1.1 was very old. Are you able to try newer release ? > Kafka 8.1.1 -

[jira] [Commented] (KAFKA-6013) Controller getting stuck

2017-10-10 Thread Ivan Babrou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199031#comment-16199031 ] Ivan Babrou commented on KAFKA-6013: I restarted one node again today and controller forgot to pick it

[jira] [Updated] (KAFKA-6023) ThreadCache#sizeBytes() should check overflow

2017-10-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6023: --- Component/s: streams > ThreadCache#sizeBytes() should check overflow >

[jira] [Commented] (KAFKA-6046) DeleteRecordsRequest to a non-leader

2017-10-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199004#comment-16199004 ] ASF GitHub Bot commented on KAFKA-6046: --- GitHub user tedyu opened a pull request:

[jira] [Commented] (KAFKA-1716) hang during shutdown of ZookeeperConsumerConnector

2017-10-10 Thread Ramkumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198786#comment-16198786 ] Ramkumar commented on KAFKA-1716: - Is any solution found on this? > hang during shutdown of

[jira] [Commented] (KAFKA-6027) System test failure: LogDirFailureTest

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

[jira] [Comment Edited] (KAFKA-4905) StreamPartitionAssignor doesn't respect subscriptions to assign partitions.

2017-10-10 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198776#comment-16198776 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-4905 at 10/10/17 2:53 PM:

[jira] [Reopened] (KAFKA-5140) Flaky ResetIntegrationTest

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-5140: -- Assignee: Guozhang Wang (was: Matthias J. Sax) Looking into this issue. > Flaky

[jira] [Commented] (KAFKA-4905) StreamPartitionAssignor doesn't respect subscriptions to assign partitions.

2017-10-10 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198776#comment-16198776 ] Seweryn Habdank-Wojewodzki commented on KAFKA-4905: --- [~fredriv] What exactly means:

[jira] [Updated] (KAFKA-6045) All access to log should fail if log is closed

2017-10-10 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6045: --- Fix Version/s: 1.1.0 > All access to log should fail if log is closed >

[jira] [Created] (KAFKA-6046) DeleteRecordsRequest to a non-leader

2017-10-10 Thread Tom Bentley (JIRA)
Tom Bentley created KAFKA-6046: -- Summary: DeleteRecordsRequest to a non-leader Key: KAFKA-6046 URL: https://issues.apache.org/jira/browse/KAFKA-6046 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6046) DeleteRecordsRequest to a non-leader

2017-10-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198932#comment-16198932 ] Ted Yu commented on KAFKA-6046: --- Looking at core/src/main/scala/kafka/server/DelayedDeleteRecords.scala :

[jira] [Assigned] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Konstantine Karantasis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis reassigned KAFKA-6007: - Assignee: Konstantine Karantasis > Connect can't validate against

[jira] [Commented] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Konstantine Karantasis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199252#comment-16199252 ] Konstantine Karantasis commented on KAFKA-6007: --- My explanation so far is as follows:

[jira] [Commented] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

2017-10-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199292#comment-16199292 ] Ted Yu commented on KAFKA-6043: --- Did you see who is holding 0x00076b2e1508 ? > Kafka 8.1.1 - >

[jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6007: - Component/s: KafkaConnect > Connect can't validate against transforms in

[jira] [Commented] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

2017-10-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199314#comment-16199314 ] Jun Rao commented on KAFKA-6029: One of the issues that can lead to this is that the follower and the

[jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Konstantine Karantasis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6007: -- Affects Version/s: (was: 0.11.0.1) 0.11.0.0 >

[jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Konstantine Karantasis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6007: -- Fix Version/s: 1.0.0 0.11.0.1 > Connect can't validate

[jira] [Commented] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

2017-10-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199291#comment-16199291 ] Ted Yu commented on KAFKA-6043: --- bq. locked <0x00076a922c40> (a java.lang.Object) This is the

[jira] [Updated] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

2017-10-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6043: -- Attachment: 6043.v1 > Kafka 8.1.1 - >

[jira] [Commented] (KAFKA-6028) Improve the quota throttle communication.

2017-10-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199316#comment-16199316 ] Jun Rao commented on KAFKA-6028: Another way to address this is what's described in

[jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Konstantine Karantasis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6007: -- Priority: Blocker (was: Major) > Connect can't validate against transforms in

[jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Konstantine Karantasis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6007: -- Affects Version/s: 1.0.0 0.11.0.1 > Connect can't

[jira] [Assigned] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats

2017-10-10 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu reassigned KAFKA-5212: - Assignee: Richard Yu > Consumer ListOffsets request can starve group heartbeats >

[jira] [Commented] (KAFKA-5541) Streams should not re-throw if suspending/closing tasks fails

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

[jira] [Commented] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Stephane Maarek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199387#comment-16199387 ] Stephane Maarek commented on KAFKA-6007: I agree. You are correct in your assessment. Overall this

[jira] [Assigned] (KAFKA-6025) there is something wrong in kafka stream document

2017-10-10 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-6025: -- Assignee: Bill Bejeck > there is something wrong in kafka stream document >

[jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Konstantine Karantasis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6007: -- Priority: Major (was: Blocker) > Connect can't validate against transforms in

[jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Konstantine Karantasis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6007: -- Fix Version/s: (was: 0.11.0.1) (was: 1.0.0)

[jira] [Commented] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Konstantine Karantasis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199399#comment-16199399 ] Konstantine Karantasis commented on KAFKA-6007: --- I agree. Thanks

[jira] [Commented] (KAFKA-6025) there is something wrong in kafka stream document

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

[jira] [Updated] (KAFKA-6025) There is something wrong in Kafka Streams document

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6025: - Summary: There is something wrong in Kafka Streams document (was: there is something wrong in

[jira] [Commented] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199478#comment-16199478 ] Randall Hauch commented on KAFKA-6007: -- [~kkonstantine], thanks for the excellent diagnosis and

[jira] [Commented] (KAFKA-6022) mirror maker stores offset in zookeeper

2017-10-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198271#comment-16198271 ] Manikumar commented on KAFKA-6022: -- looks like you are using old consumer API on mirror maker. By

[jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path

2017-10-10 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6007: - Fix Version/s: (was: 0.10.0.2) 0.11.0.2 > Connect can't validate against

[jira] [Created] (KAFKA-6048) Support negative record timestamps

2017-10-10 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-6048: -- Summary: Support negative record timestamps Key: KAFKA-6048 URL: https://issues.apache.org/jira/browse/KAFKA-6048 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6049: - Description: When multiple streams aggregate together to form a single larger object (e.g. A

[jira] [Commented] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199649#comment-16199649 ] Guozhang Wang commented on KAFKA-6049: -- Thanks [~tedyu], fixing now. > Kafka Streams: Add Cogroup in

[jira] [Updated] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

2017-10-10 Thread Ramkumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ramkumar updated KAFKA-6043: Attachment: stdout.LRMIID-158150.zip Attaching the complete thread dump with this file . > Kafka 8.1.1 -

[jira] [Commented] (KAFKA-6028) Improve the quota throttle communication.

2017-10-10 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199712#comment-16199712 ] Jiangjie Qin commented on KAFKA-6028: - [~junrao] Not sure if this is going to solve the problem. The

[jira] [Commented] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

2017-10-10 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199706#comment-16199706 ] Jiangjie Qin commented on KAFKA-6029: - [~junrao] Good point. That seems more likely to happen. Just to

[jira] [Comment Edited] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats

2017-10-10 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199778#comment-16199778 ] Richard Yu edited comment on KAFKA-5212 at 10/11/17 4:06 AM: - [~hachikuji]

[jira] [Commented] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats

2017-10-10 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199778#comment-16199778 ] Richard Yu commented on KAFKA-5212: --- During some study after the failure of my most recent commit, there

[jira] [Comment Edited] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199642#comment-16199642 ] Guozhang Wang edited comment on KAFKA-6049 at 10/11/17 12:59 AM: - WIP PR

[jira] [Commented] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199643#comment-16199643 ] Guozhang Wang commented on KAFKA-6049: -- This is primarily contributed by [~winkelman.kyle]. I'm

[jira] [Comment Edited] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

2017-10-10 Thread Ramkumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199667#comment-16199667 ] Ramkumar edited comment on KAFKA-6043 at 10/11/17 1:24 AM: --- Hi Ted, thanks for

[jira] [Comment Edited] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats

2017-10-10 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199778#comment-16199778 ] Richard Yu edited comment on KAFKA-5212 at 10/11/17 4:08 AM: - [~hachikuji]

[jira] [Commented] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199642#comment-16199642 ] Guozhang Wang commented on KAFKA-6049: -- WIP PR ready at

[jira] [Assigned] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-6049: Assignee: (was: Kyle Winkelman) > Kafka Streams: Add Cogroup in the DSL >

[jira] [Commented] (KAFKA-6028) Improve the quota throttle communication.

2017-10-10 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199806#comment-16199806 ] Jiangjie Qin commented on KAFKA-6028: - [~junrao] We were thinking that the server will mute the

[jira] [Commented] (KAFKA-6022) mirror maker stores offset in zookeeper

2017-10-10 Thread Ronald van de Kuil (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199804#comment-16199804 ] Ronald van de Kuil commented on KAFKA-6022: --- Hi Manikumar, I see that I copied the mirror

[jira] [Resolved] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5977. -- Resolution: Fixed > Upgrade RocksDB dependency to legally acceptable version >

[jira] [Reopened] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-5977: -- > Upgrade RocksDB dependency to legally acceptable version >

[jira] [Commented] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2017-10-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199645#comment-16199645 ] Ted Yu commented on KAFKA-6049: --- bq. ValueGetters keep calling ValueGetters until Is there typo above ? >

[jira] [Created] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2017-10-10 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6049: Summary: Kafka Streams: Add Cogroup in the DSL Key: KAFKA-6049 URL: https://issues.apache.org/jira/browse/KAFKA-6049 Project: Kafka Issue Type: New Feature

[jira] [Updated] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6049: - Description: When multiple streams aggregate together to form a single larger object (e.g. A

[jira] [Comment Edited] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats

2017-10-10 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199778#comment-16199778 ] Richard Yu edited comment on KAFKA-5212 at 10/11/17 4:10 AM: - [~hachikuji]

[jira] [Commented] (KAFKA-6028) Improve the quota throttle communication.

2017-10-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199792#comment-16199792 ] Jun Rao commented on KAFKA-6028: [~becket_qin], the window size is configurable and we can reduce the

[jira] [Commented] (KAFKA-6022) mirror maker stores offset in zookeeper

2017-10-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199814#comment-16199814 ] Manikumar commented on KAFKA-6022: -- I think we missed to update consumer.properties file. Will raise a

[jira] [Updated] (KAFKA-5573) kaka-clients 0.11.0.0 AdminClient#createTopics() does not set configs

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5573: - Fix Version/s: (was: 1.0.0) > kaka-clients 0.11.0.0 AdminClient#createTopics() does not set

[jira] [Updated] (KAFKA-5300) Improve exception handling on producer path

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5300: - Fix Version/s: (was: 1.0.0) > Improve exception handling on producer path >

[jira] [Updated] (KAFKA-5011) Replica fetchers may need to down-convert messages during a selective message format upgrade

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5011: - Fix Version/s: (was: 1.0.0) > Replica fetchers may need to down-convert messages during a

[jira] [Updated] (KAFKA-5499) Double check how we handle exceptions when commits fail

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5499: - Fix Version/s: (was: 1.0.0) > Double check how we handle exceptions when commits fail >

[jira] [Updated] (KAFKA-5640) Look into making acks=all the default setting

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5640: - Fix Version/s: (was: 1.0.0) > Look into making acks=all the default setting >

[jira] [Updated] (KAFKA-5569) Document any changes from this task

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5569: - Fix Version/s: (was: 1.0.0) > Document any changes from this task >

[jira] [Updated] (KAFKA-5621) The producer should retry expired batches when retries are enabled

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5621: - Fix Version/s: (was: 1.0.0) > The producer should retry expired batches when retries are

[jira] [Updated] (KAFKA-4563) State transitions error PARTITIONS_REVOKED to NOT_RUNNING

2017-10-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4563: - Fix Version/s: (was: 1.0.0) > State transitions error PARTITIONS_REVOKED to NOT_RUNNING >

[jira] [Commented] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

2017-10-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199794#comment-16199794 ] Jun Rao commented on KAFKA-6029: [~becket_qin], yes, that's the rough idea. > Controller should wait for