[jira] [Assigned] (KAFKA-2071) Replace Produce Request/Response with their org.apache.kafka.common.requests equivalents

[ https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot reassigned KAFKA-2071: -- Assignee: David Jacot > Replace Produce Request/Response with their org.apache.kafka.common.req

[jira] [Updated] (KAFKA-2143) Replicas get ahead of leader and fail

[ https://issues.apache.org/jira/browse/KAFKA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2143: Fix Version/s: 0.8.3 Status: Patch Available (was: Open) > Replicas get ahead of leader

[jira] [Updated] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2334: Status: Open (was: Patch Available) > Prevent HW from going back during leader failover >

[jira] [Updated] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2334: Component/s: replication > Prevent HW from going back during leader failover >

[jira] [Updated] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2334: Assignee: Neha Narkhede (was: Jiangjie Qin) > Prevent HW from going back during leader failover >

[jira] [Updated] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2334: Fix Version/s: (was: 0.8.3) 0.9.0 > Prevent HW from going back during leader

[jira] [Updated] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2334: Fix Version/s: (was: 0.9.0) 0.8.3 Status: Patch Available (was: In

[jira] [Updated] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2334: Affects Version/s: 0.8.2.1 > Prevent HW from going back during leader failover > --

[jira] [Work started] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2334 started by Jiangjie Qin. --- > Prevent HW from going back during leader failover >

[jira] [Commented] (KAFKA-2143) Replicas get ahead of leader and fail

[ https://issues.apache.org/jira/browse/KAFKA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14651344#comment-14651344 ] Jiangjie Qin commented on KAFKA-2143: - Actually I realized KAFKA-2334 is orthogonal to

[jira] [Commented] (KAFKA-2134) Producer blocked on metric publish

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

[GitHub] kafka pull request: Fix for KAFKA-2134, fix replica offset truncat...

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/104 Fix for KAFKA-2134, fix replica offset truncate to beginning during leader migration. Fix replica truncate log to beginning during leader migration. You can merge this pull request into a Git repo

[jira] [Created] (KAFKA-2398) Transient test failure for SocketServerTest - Socket closed.

Jiangjie Qin created KAFKA-2398: --- Summary: Transient test failure for SocketServerTest - Socket closed. Key: KAFKA-2398 URL: https://issues.apache.org/jira/browse/KAFKA-2398 Project: Kafka Iss

[jira] [Updated] (KAFKA-2303) Fix for KAFKA-2235 LogCleaner offset map overflow causes another compaction failures

[ https://issues.apache.org/jira/browse/KAFKA-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2303: - Assignee: Guozhang Wang (was: Jay Kreps) > Fix for KAFKA-2235 LogCleaner offset map overflow caus

Re: Kafka Consumer thoughts

No the purpose of pause/resume was to be able to implement prioritization of processing by partition. i.e. if you want to prioritize a given subset of partitions without rebalancing them to another consumer you pause the others and continue reading. -Jay On Fri, Jul 31, 2015 at 4:55 PM, Jun Rao

Re: Review Request 36722: Patch for KAFKA-2332

> On July 23, 2015, 5:56 p.m., Aditya Auradkar wrote: > > core/src/main/scala/kafka/consumer/SimpleConsumer.scala, line 138 > > > > > > same comment about null fetchRequestAndResponseStats.getFetchRequestAndResponse

[jira] [Updated] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-2397: Status: Patch Available (was: In Progress) > leave group request > --- > >

[jira] [Work started] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2397 started by Onur Karaman. --- > leave group request > --- > > Key: KAFKA-2397 >

Re: kafka - tcp ports

It does not. That last connection, the one in CLOSE_WAIT, is an outbound connection from the broker you are looking at to one of the other brokers. 57821 is the source TCP port, and it is selected (somewhat) randomly from a range of high port numbers. Note that the other end of the connection is 90

kafka - tcp ports

hi all, i am monitoring the ports that are used by kafka server on my machine. When i do, sudo netstat -ntp | grep 9092 it shows, tcp0 0 192.168.122.1:9092 192.168.122.6:59158 ESTABLISHED 27413/java tcp0 0 192.168.122.1:9092 192.168.122.1:58338 ESTABLISHED

[jira] [Commented] (KAFKA-2397) leave group request

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

[GitHub] kafka pull request: KAFKA-2397: leave group request

GitHub user onurkaraman opened a pull request: https://github.com/apache/kafka/pull/103 KAFKA-2397: leave group request You can merge this pull request into a Git repository by running: $ git pull https://github.com/onurkaraman/kafka leave-group Alternatively you can review a

[jira] [Updated] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-2397: Description: Let's say every consumer in a group has session timeout s. Currently, if a consumer le

[jira] [Created] (KAFKA-2397) leave group request

Onur Karaman created KAFKA-2397: --- Summary: leave group request Key: KAFKA-2397 URL: https://issues.apache.org/jira/browse/KAFKA-2397 Project: Kafka Issue Type: Sub-task Reporter: On