[GitHub] kafka pull request #1906: KAFKA-4216: Control Leader & Follower Throttled Re...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1906 --- 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 enab

[jira] [Commented] (KAFKA-4216) Replication Quotas: Control Leader & Follower Throttled Replicas Separately

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

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532092#comment-15532092 ] Harald Kirsch commented on KAFKA-1194: -- [~abhit011] The patch described in https://

[jira] [Created] (KAFKA-4229) Controller can't start after serveral zk expired event

Pengwei created KAFKA-4229: -- Summary: Controller can't start after serveral zk expired event Key: KAFKA-4229 URL: https://issues.apache.org/jira/browse/KAFKA-4229 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-4230) HistogramSample needs override Sample's reset method

Xing Huang created KAFKA-4230: - Summary: HistogramSample needs override Sample's reset method Key: KAFKA-4230 URL: https://issues.apache.org/jira/browse/KAFKA-4230 Project: Kafka Issue Type: Bug

[GitHub] kafka pull request #1928: KAFKA-4225: Replication Quotas: Control Leader & F...

Github user benstopford closed the pull request at: https://github.com/apache/kafka/pull/1928 --- 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

[jira] [Commented] (KAFKA-4225) Replication Quotas: Control Leader & Follower Limit Separately

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

[jira] [Updated] (KAFKA-4216) Replication Quotas: Control Leader & Follower Throttled Replicas Separately

[ https://issues.apache.org/jira/browse/KAFKA-4216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4216: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 1906

[GitHub] kafka pull request #1932: KAFKA-4225: Replication Quotas: Control Leader & F...

GitHub user benstopford opened a pull request: https://github.com/apache/kafka/pull/1932 KAFKA-4225: Replication Quotas: Control Leader & Follower Limit Separately You can merge this pull request into a Git repository by running: $ git pull https://github.com/benstopford/kafka

[jira] [Commented] (KAFKA-4225) Replication Quotas: Control Leader & Follower Limit Separately

[ https://issues.apache.org/jira/browse/KAFKA-4225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532153#comment-15532153 ] ASF GitHub Bot commented on KAFKA-4225: --- GitHub user benstopford opened a pull reque

[GitHub] kafka pull request #1933: KAFKA-4230: HistogramSample needs override Sample'...

GitHub user iBuddha opened a pull request: https://github.com/apache/kafka/pull/1933 KAFKA-4230: HistogramSample needs override Sample's reset method You can merge this pull request into a Git repository by running: $ git pull https://github.com/iBuddha/kafka trunk Alternativ

[jira] [Commented] (KAFKA-4230) HistogramSample needs override Sample's reset method

[ https://issues.apache.org/jira/browse/KAFKA-4230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532178#comment-15532178 ] ASF GitHub Bot commented on KAFKA-4230: --- GitHub user iBuddha opened a pull request:

Build failed in Jenkins: kafka-0.10.1-jdk7 #22

See Changes: [jason] MINOR: Set JVM parameters for the Gradle Test executor processes -- [...truncated 11884 lines...] org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > tes

[jira] [Updated] (KAFKA-4229) Controller can't start after serveral zk expired event

[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-4229: --- Fix Version/s: (was: 0.10.1.0) > Controller can't start after serveral zk expired event >

[jira] [Updated] (KAFKA-4229) Controller can't start after serveral zk expired event

[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-4229: --- Fix Version/s: 0.10.1.0 > Controller can't start after serveral zk expired event > ---

[jira] [Comment Edited] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15531897#comment-15531897 ] Abhi edited comment on KAFKA-1194 at 9/29/16 9:04 AM: -- Hello Even I

[jira] [Commented] (KAFKA-4229) Controller can't start after serveral zk expired event

[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532241#comment-15532241 ] Pengwei commented on KAFKA-4229: I already have a patch for this issue, maybe the issue ca

Build failed in Jenkins: kafka-trunk-jdk8 #925

See Changes: [ismael] HOTFIX: Tools for releases prior to 0.10.1 need --new-consumer flag -- [...truncated 13787 lines...] org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest

[jira] [Assigned] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey

[ https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4186: - Assignee: Damian Guy > Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey >

[jira] [Work started] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey

[ https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4186 started by Damian Guy. - > Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey > ---

Build failed in Jenkins: kafka-trunk-jdk7 #1583

See Changes: [ismael] HOTFIX: Tools for releases prior to 0.10.1 need --new-consumer flag -- [...truncated 13761 lines...] org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTes

Jenkins build is back to normal : kafka-0.10.1-jdk7 #23

See

Build failed in Jenkins: kafka-trunk-jdk8 #926

See Changes: [ismael] KAFKA-4216; Control Leader & Follower Throttled Replicas Separately -- [...truncated 13798 lines...] org.apache.kafka.streams.kstream.internals.KeyValuePrinterProcessorTest

Jenkins build is back to normal : kafka-trunk-jdk7 #1584

See

[jira] [Created] (KAFKA-4231) ZK metadata went inconsistent when migrating 0.10.0.0 -> 0.10.0.1

Sergey Alaev created KAFKA-4231: --- Summary: ZK metadata went inconsistent when migrating 0.10.0.0 -> 0.10.0.1 Key: KAFKA-4231 URL: https://issues.apache.org/jira/browse/KAFKA-4231 Project: Kafka

[jira] [Commented] (KAFKA-4231) ZK metadata went inconsistent when migrating 0.10.0.0 -> 0.10.0.1

[ https://issues.apache.org/jira/browse/KAFKA-4231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532791#comment-15532791 ] Ismael Juma commented on KAFKA-4231: I'm not aware of any reason why 0.10.0.1 should a

[jira] [Updated] (KAFKA-4225) Replication Quotas: Control Leader & Follower Limit Separately

[ https://issues.apache.org/jira/browse/KAFKA-4225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4225: --- Status: Patch Available (was: Open) > Replication Quotas: Control Leader & Follower Limit Separately

[jira] [Commented] (KAFKA-3895) Implement a default queue for expired messages

[ https://issues.apache.org/jira/browse/KAFKA-3895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533221#comment-15533221 ] Jeff Klukas commented on KAFKA-3895: It's not clear to me how the concepts here map on

[GitHub] kafka pull request #1934: KAFKA-4206 Improve handling of invalid credentials...

GitHub user edoardocomar opened a pull request: https://github.com/apache/kafka/pull/1934 KAFKA-4206 Improve handling of invalid credentials to mitigate DOS issue Delay closing channels for connections where a SALException has been thrown. This PR is a proof of concept a

[jira] [Commented] (KAFKA-4206) Improve handling of invalid credentials to mitigate DOS issue (especially on SSL listeners)

[ https://issues.apache.org/jira/browse/KAFKA-4206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533233#comment-15533233 ] ASF GitHub Bot commented on KAFKA-4206: --- GitHub user edoardocomar opened a pull requ

Re: [DISCUSS] KIP-48 Support for delegation tokens as an authentication mechanism

Harsha/ Gwen, How do we proceed here? I am willing to help out with here. On Fri, Sep 23, 2016 at 11:41 AM, Gwen Shapira wrote: > Is it updated? are all concerns addressed? do you want to start a vote? > > Sorry for being pushy, I do appreciate that we are all volunteers and > finding time is d

[jira] [Created] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

Jiangjie Qin created KAFKA-4232: --- Summary: IllegalStateException may be thrown from producer.send() when a batch is full. Key: KAFKA-4232 URL: https://issues.apache.org/jira/browse/KAFKA-4232 Project: K

[jira] [Updated] (KAFKA-3697) Clean-up website documentation when it comes to clients

[ https://issues.apache.org/jira/browse/KAFKA-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-3697: --- Status: Patch Available (was: Open) > Clean-up website documentation when it comes to clients

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533461#comment-15533461 ] Ismael Juma commented on KAFKA-4232: Thanks for the report. Just to check, are you goi

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533497#comment-15533497 ] Jiangjie Qin commented on KAFKA-4232: - It looks the issue is that we need to make Memo

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533508#comment-15533508 ] Jiangjie Qin commented on KAFKA-4232: - I'll submit a PR shortly. > IllegalStateExcept

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533524#comment-15533524 ] Ismael Juma commented on KAFKA-4232: I see. I was wondering about the following commen

[GitHub] kafka pull request #1935: KAFKA-4232: make MemoryRecords.writable volatile.

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/1935 KAFKA-4232: make MemoryRecords.writable volatile. You can merge this pull request into a Git repository by running: $ git pull https://github.com/becketqin/kafka KAFKA-4232 Alternatively yo

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533566#comment-15533566 ] ASF GitHub Bot commented on KAFKA-4232: --- GitHub user becketqin opened a pull request

[jira] [Updated] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4232: Status: Patch Available (was: Open) > IllegalStateException may be thrown from producer.send() when

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533584#comment-15533584 ] Jiangjie Qin commented on KAFKA-4232: - Yes. The description was not accurate. I was in

[jira] [Issue Comment Deleted] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4232: Comment: was deleted (was: Yes. The description was not accurate. I was initially thinking it was b

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533583#comment-15533583 ] Jiangjie Qin commented on KAFKA-4232: - Yes. The description was not accurate. I was in

[jira] [Updated] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4232: Description: MemoryRecords.writable should be volatile. (was: We used to leave the batch not closed

[jira] [Assigned] (KAFKA-4226) Surprising NoOffsetForPartitionException for paused partition with no reset policy

[ https://issues.apache.org/jira/browse/KAFKA-4226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-4226: -- Assignee: Vahid Hashemian > Surprising NoOffsetForPartitionException for paused partiti

[jira] [Created] (KAFKA-4233) StateDirectory fails to create directory if any parent directory does not exist

Ryan Worsley created KAFKA-4233: --- Summary: StateDirectory fails to create directory if any parent directory does not exist Key: KAFKA-4233 URL: https://issues.apache.org/jira/browse/KAFKA-4233 Project:

[GitHub] kafka pull request #1909: MINOR: Allow for asynchronous start of producer co...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1909 --- 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 enab

[jira] [Commented] (KAFKA-4226) Surprising NoOffsetForPartitionException for paused partition with no reset policy

[ https://issues.apache.org/jira/browse/KAFKA-4226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534035#comment-15534035 ] Jason Gustafson commented on KAFKA-4226: [~vahid] Before jumping in and implementi

[jira] [Commented] (KAFKA-2359) New consumer - partitions auto assigned only on poll

[ https://issues.apache.org/jira/browse/KAFKA-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534119#comment-15534119 ] Tamas Cserveny commented on KAFKA-2359: --- Hi, We were struggling with this problem a

[jira] [Updated] (KAFKA-4058) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4058: - Fix Version/s: (was: 0.10.1.0) > Failure in > org.apache.kafka.streams.integration.ResetInteg

[jira] [Reopened] (KAFKA-4058) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4058: -- > Failure in > org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratc

[jira] [Commented] (KAFKA-4058) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534236#comment-15534236 ] Guozhang Wang commented on KAFKA-4058: -- I saw this test failing a couple of time in t

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534261#comment-15534261 ] Jiangjie Qin commented on KAFKA-4232: - [~ijuma] Actually I am looking at the java memo

Re: [DISCUSS] KIP-80: Kafka REST Server

Thanks Mani for the KIP. I'll go over it and add my thoughts on this thread. On Wed, Sep 28, 2016 at 12:04 AM Manikumar wrote: > Hi Kafka Devs, > > I created KIP-80 to add Kafka REST Server to Kafka Repository. > > There are already open-source alternatives are available. But we would > like to

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534276#comment-15534276 ] Ismael Juma commented on KAFKA-4232: That's a good point [~becket_qin], the synchroniz

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534301#comment-15534301 ] Guozhang Wang commented on KAFKA-4212: -- I said {{so If you create a hopping windowed

[jira] [Commented] (KAFKA-4226) Surprising NoOffsetForPartitionException for paused partition with no reset policy

[ https://issues.apache.org/jira/browse/KAFKA-4226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534319#comment-15534319 ] Guozhang Wang commented on KAFKA-4226: -- [~hachikuji] Is this tackled by KAFKA-3370 as

[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=15534326#comment-15534326 ] James Cheng commented on KAFKA-3410: [~junrao], [~tcrayford-heroku], can I get your op

[GitHub] kafka pull request #1936: KAFKA-3824: Clarify autocommit delivery semantics ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1936 KAFKA-3824: Clarify autocommit delivery semantics for consumer You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-3824 Alt

[jira] [Commented] (KAFKA-3824) Docs indicate auto.commit breaks at least once delivery but that is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-3824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534329#comment-15534329 ] ASF GitHub Bot commented on KAFKA-3824: --- GitHub user hachikuji opened a pull request

[GitHub] kafka pull request #1937: KAFKA-4108: Improve DumpLogSegments offsets-decode...

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/1937 KAFKA-4108: Improve DumpLogSegments offsets-decoder output format This PR improves the output format of DumpLogSegments when the `--offset-decoder` option is used for consuming `__consumer_of

[jira] [Updated] (KAFKA-4108) Improve DumpLogSegments offsets-decoder output format

[ https://issues.apache.org/jira/browse/KAFKA-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-4108: --- Status: Patch Available (was: Open) > Improve DumpLogSegments offsets-decoder output format >

[jira] [Commented] (KAFKA-4108) Improve DumpLogSegments offsets-decoder output format

[ https://issues.apache.org/jira/browse/KAFKA-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534350#comment-15534350 ] ASF GitHub Bot commented on KAFKA-4108: --- GitHub user vahidhashemian opened a pull re

[GitHub] kafka pull request #1938: KAFKA-4058: improved test condition evaluation

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/1938 KAFKA-4058: improved test condition evaluation You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka kafka-4058-resetIntegartionTest Altern

[jira] [Commented] (KAFKA-4058) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534400#comment-15534400 ] ASF GitHub Bot commented on KAFKA-4058: --- GitHub user mjsax opened a pull request:

[jira] [Commented] (KAFKA-4217) KStream.transform equivalent of flatMap

[ https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534404#comment-15534404 ] Guozhang Wang commented on KAFKA-4217: -- Is this related to https://issues.apache.org/

Build failed in Jenkins: kafka-trunk-jdk8 #927

See Changes: [jason] MINOR: Allow for asynchronous start of producer consumer in validation -- [...truncated 3710 lines...] kafka.coordinator.GroupMetadataManagerTest > testExpireGroup STARTED k

[jira] [Updated] (KAFKA-3965) Mirror maker sync send fails will lose messages

[ https://issues.apache.org/jira/browse/KAFKA-3965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3965: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull requ

[jira] [Commented] (KAFKA-3965) Mirror maker sync send fails will lose messages

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

[GitHub] kafka pull request #1915: KAFKA-3965 mirror maker should not commit offset w...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1915 --- 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 enab

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534446#comment-15534446 ] Jiangjie Qin commented on KAFKA-4232: - [~ijuma] I double checked the code that thrown

[jira] [Comment Edited] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534446#comment-15534446 ] Jiangjie Qin edited comment on KAFKA-4232 at 9/29/16 11:52 PM: -

[jira] [Updated] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-4232: Resolution: Won't Fix Fix Version/s: (was: 0.10.1.0) 0.10.0.0

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

[ https://issues.apache.org/jira/browse/KAFKA-4232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534464#comment-15534464 ] Ismael Juma commented on KAFKA-4232: No problem, thanks for checking. :) > IllegalSta

[jira] [Commented] (KAFKA-4234) Consumer should not commit offsets in unsubscribe()

[ https://issues.apache.org/jira/browse/KAFKA-4234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534483#comment-15534483 ] Jason Gustafson commented on KAFKA-4234: [~vahid] Does this make sense to you? >

[jira] [Created] (KAFKA-4234) Consumer should not commit offsets in unsubscribe()

Jason Gustafson created KAFKA-4234: -- Summary: Consumer should not commit offsets in unsubscribe() Key: KAFKA-4234 URL: https://issues.apache.org/jira/browse/KAFKA-4234 Project: Kafka Issue T

[GitHub] kafka pull request #1935: KAFKA-4232: make MemoryRecords.writable volatile.

Github user becketqin closed the pull request at: https://github.com/apache/kafka/pull/1935 --- 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 e

[jira] [Created] (KAFKA-4235) Fix the closing order in Sender.initiateClose().

Jiangjie Qin created KAFKA-4235: --- Summary: Fix the closing order in Sender.initiateClose(). Key: KAFKA-4235 URL: https://issues.apache.org/jira/browse/KAFKA-4235 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-4232) IllegalStateException may be thrown from producer.send() when a batch is full.

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

[GitHub] kafka pull request #1939: KAFKA-4235: Fix the race condition in Sender.initi...

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/1939 KAFKA-4235: Fix the race condition in Sender.initiateClose() that may result in missing some callbacks. You can merge this pull request into a Git repository by running: $ git pull https://

[jira] [Commented] (KAFKA-4235) Fix the closing order in Sender.initiateClose().

[ https://issues.apache.org/jira/browse/KAFKA-4235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534556#comment-15534556 ] ASF GitHub Bot commented on KAFKA-4235: --- GitHub user becketqin opened a pull request

Build failed in Jenkins: kafka-0.10.1-jdk7 #24

See Changes: [jason] MINOR: Allow for asynchronous start of producer consumer in validation -- [...truncated 3705 lines...] kafka.api.AuthorizerIntegrationTest > testProduceWithTopicRead STARTED

Build failed in Jenkins: kafka-trunk-jdk8 #928

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on jenkins-test-486 (Ubuntu ubuntu jenkins-cloud-8GB jenkins-cloud-4GB cloud-slave) in workspace

Build failed in Jenkins: kafka-0.10.1-jdk7 #25

See -- Started by an SCM change Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on jenkins-test-486 (Ubuntu ubuntu jenkins-cloud-8GB jenkins-cloud-4GB cloud-s

Build failed in Jenkins: kafka-trunk-jdk8 #929

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on jenkins-test-486 (Ubuntu ubuntu jenkins-cloud-8GB jenkins-cloud-4GB cloud-slave) in workspace

[jira] [Commented] (KAFKA-4234) Consumer should not commit offsets in unsubscribe()

[ https://issues.apache.org/jira/browse/KAFKA-4234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534708#comment-15534708 ] Vahid Hashemian commented on KAFKA-4234: [~hachikuji] I read the comments on [KAF

Build failed in Jenkins: kafka-0.10.1-jdk7 #26

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on jenkins-test-486 (Ubuntu ubuntu jenkins-cloud-8GB jenkins-cloud-4GB cloud-slave) in workspace

Build failed in Jenkins: kafka-trunk-jdk7 #1585

See Changes: [jason] MINOR: Allow for asynchronous start of producer consumer in validation -- [...truncated 13781 lines...] org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >

[jira] [Commented] (KAFKA-4234) Consumer should not commit offsets in unsubscribe()

[ https://issues.apache.org/jira/browse/KAFKA-4234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534782#comment-15534782 ] Jason Gustafson commented on KAFKA-4234: Yeah, since there's no consensus how to a

[GitHub] kafka pull request #1921: KAFKA-3697: Update quick start documentation to us...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1921 --- 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 enab

[jira] [Commented] (KAFKA-3697) Clean-up website documentation when it comes to clients

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

[jira] [Updated] (KAFKA-3697) Clean-up website documentation when it comes to clients

[ https://issues.apache.org/jira/browse/KAFKA-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3697: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull requ

[jira] [Created] (KAFKA-4236) Create system test for KAFKA-3965

Jiangjie Qin created KAFKA-4236: --- Summary: Create system test for KAFKA-3965 Key: KAFKA-4236 URL: https://issues.apache.org/jira/browse/KAFKA-4236 Project: Kafka Issue Type: Sub-task

Build failed in Jenkins: kafka-0.10.1-jdk7 #27

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on jenkins-test-486 (Ubuntu ubuntu jenkins-cloud-8GB jenkins-cloud-4GB cloud-slave) in workspace

Build failed in Jenkins: kafka-trunk-jdk8 #930

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on jenkins-test-486 (Ubuntu ubuntu jenkins-cloud-8GB jenkins-cloud-4GB cloud-slave) in workspace

Jenkins build is back to normal : kafka-trunk-jdk7 #1586

See

[jira] [Updated] (KAFKA-4229) Controller can't start after several zk expired event

[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-4229: --- Summary: Controller can't start after several zk expired event (was: Controller can't start after serveral zk

[jira] [Updated] (KAFKA-4229) Controller can't start after several zk expired event

[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-4229: --- Description: We found the controller not started after several zk expired event in our test environment. By

[jira] [Created] (KAFKA-4237) Avoid long request timeout for the consumer

Jason Gustafson created KAFKA-4237: -- Summary: Avoid long request timeout for the consumer Key: KAFKA-4237 URL: https://issues.apache.org/jira/browse/KAFKA-4237 Project: Kafka Issue Type: Imp

Build failed in Jenkins: kafka-0.10.1-jdk7 #28

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on jenkins-test-486 (Ubuntu ubuntu jenkins-cloud-8GB jenkins-cloud-4GB cloud-slave) in workspace

  1   2   >