[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 >

[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 i

[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 delete.topic.enable

[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&focusedCommentId=15528682#comment-15528682 ] Manikumar Reddy commented on KAFKA-4074: [~hachikuji] Yes, resolving this as dupl

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 f

[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&focusedCommentId=15529088#comment-15529088 ] Anıl Chalil commented on KAFKA-3296: Is it possible to circumvent that issue by not us

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 o

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

See

[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&focusedCommentId=15529377#comment-15529377 ] Edoardo Comar commented on KAFKA-3396: -- new PR is https://github.com/apache/kafka/pul

[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 c

[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 lock-

[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 Sep

[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] [Commented] (KAFKA-2057) DelayedOperationTest.testRequestExpiry transient failure

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

[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] [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 > org.apac

[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 Iss

[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 [https://gi

[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 enab

[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&focusedCommentId=15530414#comment-15530414 ] ASF GitHub Bot commented on KAFKA-3708: --- Github user asfgit closed the pull request

[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&focusedCommentId=15530417#comment-15530417 ] Ismael Juma commented on KAFKA-2057: There is a PR for the issue that cropped up again

[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 ca

[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&focusedCommentId=15530432#comment-15530432 ] ASF GitHub Bot commented on KAFKA-4227: --- GitHub user rajinisivaram opened a pull req

[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&focusedCommentId=15530456#comment-15530456 ] Vahid Hashemian commented on KAFKA-4222: [Another example|https://builds.apache.o

[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 KStreamAggregationIntegrationTest.shouldGroupBy

[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&focusedCommentId=15530580#comment-15530580 ] Piyush Vijay commented on KAFKA-4185: - [~ecomar], even though I agree that procedure t

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 > testTrackin

[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 enab

[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 >

[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&focusedCommentId=15530699#comment-15530699 ] ASF GitHub Bot commented on KAFKA-4227: --- Github user asfgit closed the 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 >

[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 into

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

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

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

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

[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 KMino

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

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

[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&focusedCommentId=15531011#comment-15531011 ] Andrew Olson commented on KAFKA-3990: - I think this Jira can be closed as a duplicate

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

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

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

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 > testPutIfAbs

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 org.a

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

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

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

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

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

[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: https://builds.apache.org/job/kafka-trunk-git-pr-jdk7/5905/testReport/junit

[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 I

[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 enab

[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) I

[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&focusedCommentId=15531334#comment-15531334 ] ASF GitHub Bot commented on KAFKA-4209: --- Github user asfgit closed the pull request

[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 ERR

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

[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 (https://issues.apache.org/jira/

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

See

[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&focusedCommentId=15531356#comment-15531356 ] ASF GitHub Bot commented on KAFKA-4228: --- GitHub user radai-rosenblatt opened a pull

[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 e

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 "a

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.

[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 > --

[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 Se

[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 enab

[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 Avail

[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&focusedCommentId=15531433#comment-15531433 ] ASF GitHub Bot commented on KAFKA-4194: --- Github user asfgit closed the pull request

[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 > ---

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 > t

[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 enab

[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 > - > >

[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&focusedCommentId=15531570#comment-15531570 ] Matthias J. Sax commented on KAFKA-4114: Sorry for the late reply. Case #1 is alre

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 lines...

[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&focusedCommentId=15531675#comment-15531675 ] Bill Bejeck commented on KAFKA-4114: No worries on the response. Thanks for clearing

[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&focusedCommentId=15531701#comment-15531701 ] Matthias J. Sax commented on KAFKA-4114: No problem. Just shoot your questions. :)

[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 ret

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 lines...

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 lines.

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-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 > testSimpleRequestRespon

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

[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=15531897#comment-15531897 ] Abhi commented on KAFKA-1194: - Hello Even I am getting similar error when running kafka on w

[jira] [Commented] (KAFKA-4142) Log files in /data dir date modified keeps being updated?

[ https://issues.apache.org/jira/browse/KAFKA-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15531931#comment-15531931 ] Umesh Chaudhary commented on KAFKA-4142: [~cmhillerman], Did you compare the size

[GitHub] kafka pull request #1931: HOTFIX: Tools for releases prior to 0.10.1 need --...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1931 HOTFIX: Tools for releases prior to 0.10.1 need --new-consumer flag You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka fix-broken

[jira] [Commented] (KAFKA-4122) Consumer startup swallows DNS resolution exception and infinitely retries

[ https://issues.apache.org/jira/browse/KAFKA-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15531969#comment-15531969 ] Umesh Chaudhary commented on KAFKA-4122: This one looks feasible. [~junrao] [~ewe

[GitHub] kafka pull request #1931: HOTFIX: Tools for releases prior to 0.10.1 need --...

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

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

See