[jira] [Updated] (KAFKA-4551) StreamsSmokeTest.test_streams intermittent failure

[ https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4551: - Labels: system-test-failure (was: ) > StreamsSmokeTest.test_streams intermittent

[jira] [Updated] (KAFKA-4551) StreamsSmokeTest.test_streams intermittent failure

[ https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4551: - Assignee: Damian Guy > StreamsSmokeTest.test_streams intermittent failure > --

[jira] [Commented] (KAFKA-4551) StreamsSmokeTest.test_streams intermittent failure

[ https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779574#comment-15779574 ] Ewen Cheslack-Postava commented on KAFKA-4551: -- Another case of this today:

[jira] [Updated] (KAFKA-4551) StreamsSmokeTest.test_streams intermittent failure

[ https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4551: - Fix Version/s: 0.10.1.2 > StreamsSmokeTest.test_streams intermittent failure > ---

[jira] [Commented] (KAFKA-2098) Gradle Wrapper Jar gone missing in 0.8.2.1

[ https://issues.apache.org/jira/browse/KAFKA-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779116#comment-15779116 ] ASF GitHub Bot commented on KAFKA-2098: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-2229) Phase 1: Requests and KafkaApis

[ https://issues.apache.org/jira/browse/KAFKA-2229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779113#comment-15779113 ] ASF GitHub Bot commented on KAFKA-2229: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-2391) Blocking call such as position(), partitionsFor(), committed() and listTopics() should have a timeout

[ https://issues.apache.org/jira/browse/KAFKA-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779112#comment-15779112 ] ASF GitHub Bot commented on KAFKA-2391: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-2717) Add kafka logbak appender

[ https://issues.apache.org/jira/browse/KAFKA-2717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779111#comment-15779111 ] ASF GitHub Bot commented on KAFKA-2717: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-2442) QuotasTest should not fail when cpu is busy

[ https://issues.apache.org/jira/browse/KAFKA-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779109#comment-15779109 ] ASF GitHub Bot commented on KAFKA-2442: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-1543) Changing replication factor

[ https://issues.apache.org/jira/browse/KAFKA-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779114#comment-15779114 ] ASF GitHub Bot commented on KAFKA-1543: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-2170) 10 LogTest cases failed for file.renameTo failed under windows

[ https://issues.apache.org/jira/browse/KAFKA-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779115#comment-15779115 ] ASF GitHub Bot commented on KAFKA-2170: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-2698) add paused API

[ https://issues.apache.org/jira/browse/KAFKA-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779110#comment-15779110 ] ASF GitHub Bot commented on KAFKA-2698: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-1911) Log deletion on stopping replicas should be async

[ https://issues.apache.org/jira/browse/KAFKA-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779108#comment-15779108 ] ASF GitHub Bot commented on KAFKA-1911: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-1621) Standardize --messages option in perf scripts

[ https://issues.apache.org/jira/browse/KAFKA-1621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779117#comment-15779117 ] ASF GitHub Bot commented on KAFKA-1621: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-2796) add support for reassignment partition to specified logdir

[ https://issues.apache.org/jira/browse/KAFKA-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779107#comment-15779107 ] ASF GitHub Bot commented on KAFKA-2796: --- Github user pono closed the pull request at

[GitHub] kafka pull request #9: maven + windows

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/9 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled b

[GitHub] kafka pull request #46: KAFKA-1621 : Standardize --messages option

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/46 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[jira] [Commented] (KAFKA-3054) Connect Herder fail forever if sent a wrong connector config or task config

[ https://issues.apache.org/jira/browse/KAFKA-3054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779106#comment-15779106 ] ASF GitHub Bot commented on KAFKA-3054: --- Github user pono closed the pull request at

[GitHub] kafka pull request #8: Escape the . in the kafka.Kafka chain

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/8 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled b

[GitHub] kafka pull request #27: Clarify log deletion configuration options in server...

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/27 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #782: KAFKA-3054: Connect Herder fail if sent a wrong con...

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/782 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #1083: KAFKA-3378 Fix for instantly connecting SocketChan...

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/1083 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enable

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779104#comment-15779104 ] ASF GitHub Bot commented on KAFKA-2120: --- Github user pono closed the pull request at

[GitHub] kafka pull request #27: Clarify log deletion configuration options in server...

GitHub user MarkRose reopened a pull request: https://github.com/apache/kafka/pull/27 Clarify log deletion configuration options in server.properties (for 0.8.1) I spent a bit of time tracking down why files were being deleted before they reached log.retention.hours of age. It turns

[GitHub] kafka pull request #160: KAFKA-2442: Fixing transiently failing test

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/160 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #2192: MyKafka

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/2192 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enable

[GitHub] kafka pull request #398: KAFKA-2717: Add kafka logbak appender

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/398 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #1235: KAFKA-3564: Count metric always increments by 1.0

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/1235 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enable

[GitHub] kafka pull request #161: KAFKA-1543: Changing replication factor

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/161 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #34: changed List type in RequestPurgatory.Watchers

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/34 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #283: KAFKA-2391 [WIP]: add timeout to KafkaConsumer bloc...

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/283 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #636: KAFKA-1911

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/636 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #54: KAFKA-2098: gradle files

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/54 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #403: KAFKA-2698: Add paused() method to o.a.k.c.c.Consum...

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/403 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #154: KAFKA-2170, KAFKA-1194: Fixes for Windows

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/154 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #223: KAFKA-2229: KIP-4 Phase 1: Requests and KafkaApis

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/223 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #1061: TRIVIAL: remove TODO in ConsumerNetworkClient afte...

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/1061 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enable

[jira] [Commented] (KAFKA-3564) Count metric always increments by 1.0

[ https://issues.apache.org/jira/browse/KAFKA-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779103#comment-15779103 ] ASF GitHub Bot commented on KAFKA-3564: --- Github user pono closed the pull request at

[GitHub] kafka pull request #1963: MINOR: Update documentation for 0.10.1 release

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/1963 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enable

[jira] [Commented] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

[ https://issues.apache.org/jira/browse/KAFKA-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779105#comment-15779105 ] ASF GitHub Bot commented on KAFKA-3378: --- Github user pono closed the pull request at

[GitHub] kafka pull request #125: Reducing code duplication in DefaultEventHandler

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/125 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #557: MINOR: Use /usr/bin/env to find bash

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/557 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

[GitHub] kafka pull request #484: KAFKA-2796 add support for reassignment partition t...

Github user pono closed the pull request at: https://github.com/apache/kafka/pull/484 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled

custom offsets in ProduceRequest

Hi all! Suppose you have two Kafka clusters and want to replicate topics from primary cluster to secondary one. It would be very convenient for readers if the message offsets for replicated topics would be the same as for primary topics. As far as I know, currently there is no way to achieve th