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

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

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

See Changes: [jason] KAFKA-4194; Follow-up improvements/testing for ListOffsets v1 (KIP-79) -- [...truncated 11851 lines...] org.apache.kafka.clients.NetworkClientTest >

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

See -- [...truncated 22 lines...] remote: Compressing objects: 5% (790/15800) remote: Compressing objects: 6% (948/15800) remote: Compressing objects: 7% (1106/15800)

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

See Changes: [jason] KAFKA-4194; Follow-up improvements/testing for ListOffsets v1 (KIP-79) [jason] MINOR: Set JVM parameters for the Gradle Test executor processes -- [...truncated 13787

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

See Changes: [jay.kreps] MINOR: Improve introduction section in docs to better cover connect and [ismael] KAFKA-4209; Reduce run time for quota integration tests -- [...truncated 2258

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

[ https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4217: --- Description: {{KStream.transform}} gives you access to state stores while allowing you to

[jira] [Commented] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531701#comment-15531701 ] Matthias J. Sax commented on KAFKA-4114: No problem. Just shoot your questions. :) > Allow for

[jira] [Commented] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531675#comment-15531675 ] Bill Bejeck commented on KAFKA-4114: No worries on the response. Thanks for clearing things up. I

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

See Changes: [jay.kreps] MINOR: Improve introduction section in docs to better cover connect and [ismael] KAFKA-4209; Reduce run time for quota integration tests -- [...truncated 13784

[jira] [Commented] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531570#comment-15531570 ] Matthias J. Sax commented on KAFKA-4114: Sorry for the late reply. Case #1 is already supported

[jira] [Resolved] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3478. Resolution: Duplicate > Finer Stream Flow Control > - > >

[GitHub] kafka pull request #1926: MINOR: Set JVM parameters for the Gradle Test exec...

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

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

See Changes: [ismael] KAFKA-4227; Shutdown AdminManager when KafkaServer is shutdown -- [...truncated 13748 lines...] org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest >

[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: --- Fix Version/s: 0.10.1.0 > Replication Quotas: Control Leader & Follower Limit Separately >

[jira] [Commented] (KAFKA-4194) Add more tests for KIP-79

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

[jira] [Updated] (KAFKA-4194) Add more tests for KIP-79

[ https://issues.apache.org/jira/browse/KAFKA-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4194: --- Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was: Patch

[GitHub] kafka pull request #1897: KAFKA-4194 follow up patch for KIP-79

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1897 --- 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] [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: --- Priority: Critical (was: Major) > Replication Quotas: Control Leader & Follower Throttled Replicas

[jira] [Resolved] (KAFKA-3283) Remove beta from new consumer documentation

[ https://issues.apache.org/jira/browse/KAFKA-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3283. Resolution: Fixed > Remove beta from new consumer documentation >

[jira] [Updated] (KAFKA-3283) Remove beta from new consumer documentation

[ https://issues.apache.org/jira/browse/KAFKA-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3283: --- Status: Reopened (was: Closed) > Remove beta from new consumer documentation >

Website Update

Hi Kafka Fans, We just pushed an update to the website. We changed the byline from "Kafka is a pub-sub system rethought as distributed log" to "Kafka is a stream platform" - because this reflects the modern use of Kafka a lot better and stream processing systems are the use-cases we optimize for.

Including streams and connect better in site docs

Hey guys, Gwen and I took a stab at better integrating Connect and Streams in the Kafka site...they were largely absent in the api section, intro, home page, etc. Take a look and see what you think. Major changes are the following: - Changed tag line from "a distributed messaging system" to

[GitHub] kafka-site pull request #19: Try to include streams and connect better. Remo...

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/19 --- 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-4228) Sender thread death leaves KafkaProducer in a bad state

[ https://issues.apache.org/jira/browse/KAFKA-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531356#comment-15531356 ] ASF GitHub Bot commented on KAFKA-4228: --- GitHub user radai-rosenblatt opened a pull request:

[GitHub] kafka pull request #1930: KAFKA-4228 - make producer close on sender thread ...

GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/1930 KAFKA-4228 - make producer close on sender thread death, make consumer shutdown on failure to rebalance, and make MM die on any of the above. the JIRA issue

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

See

[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=15531353#comment-15531353 ] Elias Levy commented on KAFKA-4212: --- I am using the {{KStream.transform}} API, the {{Transform}}

[jira] [Updated] (KAFKA-4228) Sender thread death leaves KafkaProducer in a bad state

[ https://issues.apache.org/jira/browse/KAFKA-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt updated KAFKA-4228: Description: a KafkaProducer's Sender thread may die: {noformat} 2016/09/28 00:28:01.065

[jira] [Commented] (KAFKA-4209) Reduce time taken to run quota integration tests

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

[jira] [Updated] (KAFKA-4209) Reduce time taken to run quota integration tests

[ https://issues.apache.org/jira/browse/KAFKA-4209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4209: --- Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved (was: Patch Available)

[GitHub] kafka pull request #1902: KAFKA-4209: Reduce run time for quota integration ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1902 --- 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] [Created] (KAFKA-4228) Sender thread death leaves KafkaProducer in a bad state

radai rosenblatt created KAFKA-4228: --- Summary: Sender thread death leaves KafkaProducer in a bad state Key: KAFKA-4228 URL: https://issues.apache.org/jira/browse/KAFKA-4228 Project: Kafka

[jira] [Reopened] (KAFKA-4184) Test failure in ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle

[ https://issues.apache.org/jira/browse/KAFKA-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4184: -- This test failed again:

[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=15531263#comment-15531263 ] Guozhang Wang commented on KAFKA-4212: -- Ah I thought you are trying to apply the lower-level

[GitHub] kafka-site pull request #19: Try to include streams and connect better. Remo...

GitHub user jkreps opened a pull request: https://github.com/apache/kafka-site/pull/19 Try to include streams and connect better. Removing messaging centric… … terminology. Rewrite introduction page. Make a linked doc sections stand alone. You can merge this pull request into

[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=15531116#comment-15531116 ] Elias Levy commented on KAFKA-4212: --- But joins are not performed on hopping windows, they are performed

[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=15531077#comment-15531077 ] Guozhang Wang commented on KAFKA-4212: -- When creating the windowed store with {code}

[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=15531071#comment-15531071 ] Vahid Hashemian commented on KAFKA-4226: Thanks [~hachikuji]. It fails as the unit test as you

[jira] [Comment Edited] (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=15531071#comment-15531071 ] Vahid Hashemian edited comment on KAFKA-4226 at 9/28/16 10:30 PM: -- Thanks

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

See Changes: [wangguoz] KAFKA-3708: Better exception handling in Kafka Streams -- [...truncated 11894 lines...] org.apache.kafka.common.security.ssl.SslFactoryTest > testClientMode PASSED

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

See Changes: [wangguoz] KAFKA-3708: Better exception handling in Kafka Streams -- [...truncated 13758 lines...] org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreTest >

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

See Changes: [ismael] KAFKA-4227; Shutdown AdminManager when KafkaServer is shutdown -- [...truncated 11936 lines...]

[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=15531022#comment-15531022 ] Elias Levy commented on KAFKA-4212: --- Not sure I follow. > Add a key-value store that is a TTL

[jira] [Commented] (KAFKA-3990) Kafka New Producer may raise an OutOfMemoryError

[ https://issues.apache.org/jira/browse/KAFKA-3990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15531011#comment-15531011 ] Andrew Olson commented on KAFKA-3990: - I think this Jira can be closed as a duplicate of KAFKA-2512,

[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=15530986#comment-15530986 ] Jason Gustafson commented on KAFKA-4226: [~vahid] Are you working on a clean cluster? I was able

[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=15530995#comment-15530995 ] Elias Levy commented on KAFKA-4212: --- I would described it as a TTL, not LRU. We want the records to

[GitHub] kafka pull request #1929: HOTFIX: do not call partitioner if num partitions ...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/1929 HOTFIX: do not call partitioner if num partitions is non-positive You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka

[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=15530909#comment-15530909 ] Guozhang Wang commented on KAFKA-4212: -- Thanks for the detailed description Elias, I think a

[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=15530904#comment-15530904 ] Guozhang Wang commented on KAFKA-4212: -- Records within the same window with the same key will

[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=15530851#comment-15530851 ] Vahid Hashemian commented on KAFKA-4226: [~hachikuji] The following code does not produce any

[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=15530714#comment-15530714 ] ASF GitHub Bot commented on KAFKA-4225: --- GitHub user benstopford opened a pull request:

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

GitHub user benstopford opened a pull request: https://github.com/apache/kafka/pull/1928 KAFKA-4225: Replication Quotas: Control Leader & Follower Limit Separately See final commit. (depends on https://github.com/apache/kafka/pull/1906) You can merge this pull request

[jira] [Resolved] (KAFKA-4227) AdminManager is not shutdown when KafkaServer is shutdown

[ https://issues.apache.org/jira/browse/KAFKA-4227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4227. Resolution: Fixed > AdminManager is not shutdown when KafkaServer is shutdown >

[jira] [Commented] (KAFKA-4227) AdminManager is not shutdown when KafkaServer is shutdown

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

[jira] [Updated] (KAFKA-4227) AdminManager is not shutdown when KafkaServer is shutdown

[ https://issues.apache.org/jira/browse/KAFKA-4227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4227: --- Fix Version/s: 0.10.1.0 > AdminManager is not shutdown when KafkaServer is shutdown >

[GitHub] kafka pull request #1927: KAFKA-4227: Shutdown AdminManager when KafkaServer...

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

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

See Changes: [wangguoz] KAFKA-3708: Better exception handling in Kafka Streams -- [...truncated 13785 lines...] org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest >

[jira] [Commented] (KAFKA-4185) Abstract out password verifier in SaslServer as an injectable dependency

[ https://issues.apache.org/jira/browse/KAFKA-4185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15530580#comment-15530580 ] Piyush Vijay commented on KAFKA-4185: - [~ecomar], even though I agree that procedure to add new

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

[ https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4186: --- Fix Version/s: 0.10.1.0 > Transient failure in

[jira] [Commented] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15530456#comment-15530456 ] Vahid Hashemian commented on KAFKA-4222: [Another

[jira] [Commented] (KAFKA-4227) AdminManager is not shutdown when KafkaServer is shutdown

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

[GitHub] kafka pull request #1927: KAFKA-4227: Shutdown AdminManager when KafkaServer...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/1927 KAFKA-4227: Shutdown AdminManager when KafkaServer is shutdown Terminate topic purgatory thread in AdminManager during server shutdown to avoid threads being left around in unit tests. You

[jira] [Commented] (KAFKA-2057) DelayedOperationTest.testRequestExpiry transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15530417#comment-15530417 ] Ismael Juma commented on KAFKA-2057: There is a PR for the issue that cropped up again (and seems to

[jira] [Commented] (KAFKA-3708) Rethink exception handling in KafkaStreams

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

[GitHub] kafka pull request #1819: KAFKA-3708: rethink exception handling in Kafka St...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1819 --- 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] [Resolved] (KAFKA-3708) Rethink exception handling in KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3708. -- Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request 1819

[jira] [Created] (KAFKA-4227) AdminManager is not shutdown when KafkaServer is shutdown

Rajini Sivaram created KAFKA-4227: - Summary: AdminManager is not shutdown when KafkaServer is shutdown Key: KAFKA-4227 URL: https://issues.apache.org/jira/browse/KAFKA-4227 Project: Kafka

[jira] [Resolved] (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 ] Eno Thereska resolved KAFKA-4058. - Resolution: Fixed I haven't seen this in a while, let's resolve for now. > Failure in >

[jira] [Reopened] (KAFKA-2057) DelayedOperationTest.testRequestExpiry transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-2057: -- > DelayedOperationTest.testRequestExpiry transient failure >

[jira] [Commented] (KAFKA-2057) DelayedOperationTest.testRequestExpiry transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15530336#comment-15530336 ] Guozhang Wang commented on KAFKA-2057: -- Re-open the issue since it is observed in Jenkins again:

[jira] [Updated] (KAFKA-2057) DelayedOperationTest.testRequestExpiry transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2057: - Affects Version/s: 0.10.1.0 > DelayedOperationTest.testRequestExpiry transient failure >

[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 ] Jason Gustafson updated KAFKA-4216: --- Fix Version/s: 0.10.1.0 > Replication Quotas: Control Leader & Follower Throttled Replicas

[GitHub] kafka pull request #1926: MINOR: Set JVM parameters for the Gradle Test exec...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1926 MINOR: Set JVM parameters for the Gradle Test executor processes We suspect that the test suite hangs we have been seeing are due to PermGen exhaustion. It is a common reason for hard JVM

[GitHub] kafka pull request #1925: Remove duplicate paragraph in Log Compaction docs

GitHub user IvanVergiliev opened a pull request: https://github.com/apache/kafka/pull/1925 Remove duplicate paragraph in Log Compaction docs It seems that the last guarantee in the Log Compaction guarantees list is duplicated, so I removed the one with less formatting. In

[jira] [Commented] (KAFKA-3396) Unauthorized topics are returned to the user

[ https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15529377#comment-15529377 ] Edoardo Comar commented on KAFKA-3396: -- new PR is https://github.com/apache/kafka/pull/1908 >

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

See

Re: [DISCUSS] KIP-83 - Allow multiple SASL PLAIN authenticated Java clients in a single JVM process

Thanks Rajini and Harsha I'll update the KIP -- Edoardo Comar MQ Cloud Technologies eco...@uk.ibm.com +44 (0)1962 81 5576 IBM UK Ltd, Hursley Park, SO21 2JN IBM United Kingdom Limited Registered in England and Wales with number 741598 Registered

[jira] [Commented] (KAFKA-3296) All consumer reads hang indefinately

[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15529088#comment-15529088 ] Anıl Chalil commented on KAFKA-3296: Is it possible to circumvent that issue by not using

Re: [DISCUSS] KIP-83 - Allow multiple SASL PLAIN authenticated Java clients in a single JVM process

Edo, I was going to write a KIP for this next week :-) I was thinking along the same lines as Harsha, i.e., enable multiple LoginManagers to co-exist in a JVM. The multi-user login module in MessageHub made sense at the time to overcome the limitation in Kafka, without changing Kafka itself. But

[jira] [Commented] (KAFKA-4074) Deleting a topic can make it unavailable even if delete.topic.enable is false

[ https://issues.apache.org/jira/browse/KAFKA-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528682#comment-15528682 ] Manikumar Reddy commented on KAFKA-4074: [~hachikuji] Yes, resolving this as duplicate >

[jira] [Resolved] (KAFKA-4074) Deleting a topic can make it unavailable even if delete.topic.enable is false

[ https://issues.apache.org/jira/browse/KAFKA-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-4074. Resolution: Duplicate > Deleting a topic can make it unavailable even if

[DISCUSS] KIP-80: Kafka REST Server

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 add REST server that many users ask for under Apache Kafka repo. Many data Infra tools comes up with Rest Interface. It is useful to have

[jira] [Assigned] (KAFKA-1954) Speed Up The Unit Tests

[ https://issues.apache.org/jira/browse/KAFKA-1954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balint Molnar reassigned KAFKA-1954: Assignee: Balint Molnar (was: Sriharsha Chintalapani) > Speed Up The Unit Tests >

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

See Changes: [wangguoz] HOTFIX: fix npe in StreamsMetadataState when onChange has not been [wangguoz] MINOR: fixes a few error logging formats [wangguoz] MINOR: add test to make sure ProcessorStateManager can handle State