[jira] [Created] (KAFKA-1831) Producer does not provide any information about which host the data was sent to

2014-12-28 Thread Mark Payne (JIRA)
Mark Payne created KAFKA-1831: - Summary: Producer does not provide any information about which host the data was sent to Key: KAFKA-1831 URL: https://issues.apache.org/jira/browse/KAFKA-1831 Project:

[jira] [Created] (KAFKA-1832) Async Producer will cause 'java.net.SocketException: Too many open files' when broker host does not exist

2014-12-28 Thread barney (JIRA)
barney created KAFKA-1832: - Summary: Async Producer will cause 'java.net.SocketException: Too many open files' when broker host does not exist Key: KAFKA-1832 URL: https://issues.apache.org/jira/browse/KAFKA-1832

[jira] [Updated] (KAFKA-1832) Async Producer will cause 'java.net.SocketException: Too many open files' when broker host does not exist

2014-12-28 Thread barney (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] barney updated KAFKA-1832: -- Description: How to replay the problem: 1) producer configuration: 1.1) producer.type=async 1.2)

[jira] [Updated] (KAFKA-1832) Async Producer will cause 'java.net.SocketException: Too many open files' when broker host does not exist

2014-12-28 Thread barney (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] barney updated KAFKA-1832: -- Description: *How to replay the problem:* 1) producer configuration: 1.1) producer.type=async 1.2)

[jira] [Updated] (KAFKA-1832) Async Producer will cause 'java.net.SocketException: Too many open files' when broker host does not exist

2014-12-28 Thread barney (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] barney updated KAFKA-1832: -- Description: h3.How to replay the problem: 1) producer configuration: 1.1) producer.type=async 1.2)

[jira] [Updated] (KAFKA-1832) Async Producer will cause 'java.net.SocketException: Too many open files' when broker host does not exist

2014-12-28 Thread barney (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] barney updated KAFKA-1832: -- Description: h3.How to replay the problem: * producer configuration: ** producer.type=async **

[jira] [Updated] (KAFKA-1832) Async Producer will cause 'java.net.SocketException: Too many open files' when broker host does not exist

2014-12-28 Thread barney (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] barney updated KAFKA-1832: -- Description: h3.How to replay the problem: *producer configuration: **producer.type=async

[jira] [Updated] (KAFKA-1832) Async Producer will cause 'java.net.SocketException: Too many open files' when broker host does not exist

2014-12-28 Thread barney (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] barney updated KAFKA-1832: -- Description: h3.How to replay the problem: * producer configuration: ** producer.type=async **

kafka consumer

2014-12-28 Thread panqing...@163.com
HI, I recently learning Kafka, there are several problems 1, ActiveMQ is broker push message, consumer established the messagelistener gets the message, but the message in Kafka are consumer pull from broker, Timing acquisition from brokeror can build the listener on the broker? 2, I

[jira] [Created] (KAFKA-1833) OfflinePartitionLeaderSelector may return null leader when ISR and Assgined Broker have no common

2014-12-28 Thread xiajun (JIRA)
xiajun created KAFKA-1833: - Summary: OfflinePartitionLeaderSelector may return null leader when ISR and Assgined Broker have no common Key: KAFKA-1833 URL: https://issues.apache.org/jira/browse/KAFKA-1833

[GitHub] kafka pull request: KAFKA-1833: OfflinePartitionLeaderSelector may...

2014-12-28 Thread tedxia
GitHub user tedxia opened a pull request: https://github.com/apache/kafka/pull/39 KAFKA-1833: OfflinePartitionLeaderSelector may return null leader when ISR and Assgi... In OfflinePartitonLeaderSelector::selectLeader, when liveBrokerInIsr is not empty and have no common broker

[jira] [Commented] (KAFKA-1833) OfflinePartitionLeaderSelector may return null leader when ISR and Assgined Broker have no common

2014-12-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14259911#comment-14259911 ] ASF GitHub Bot commented on KAFKA-1833: --- GitHub user tedxia opened a pull request:

[jira] [Created] (KAFKA-1834) No Response when handle LeaderAndIsrRequest some case

2014-12-28 Thread xiajun (JIRA)
xiajun created KAFKA-1834: - Summary: No Response when handle LeaderAndIsrRequest some case Key: KAFKA-1834 URL: https://issues.apache.org/jira/browse/KAFKA-1834 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-1834) No Response when handle LeaderAndIsrRequest some case

2014-12-28 Thread xiajun (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiajun updated KAFKA-1834: -- Affects Version/s: 0.8.2 No Response when handle LeaderAndIsrRequest some case

[GitHub] kafka pull request: KAFKA-1834: No Response when handle LeaderAndI...

2014-12-28 Thread tedxia
GitHub user tedxia opened a pull request: https://github.com/apache/kafka/pull/40 KAFKA-1834: No Response when handle LeaderAndIsrRequest some case PR for [KAFKA-1834](https://issues.apache.org/jira/browse/KAFKA-1834) When a replica become leader or follower, if this broker

[jira] [Commented] (KAFKA-1834) No Response when handle LeaderAndIsrRequest some case

2014-12-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14259919#comment-14259919 ] ASF GitHub Bot commented on KAFKA-1834: --- GitHub user tedxia opened a pull request: