Re: [DISCUSS] KIP-27 - Conditional Publish

2015-07-26 Thread Ben Kirwin
So I had another look at the 'Idempotent Producer' proposal this afternoon, and made a few notes on how I think they compare; if I've made any mistakes, I'd be delighted if someone with more context on the idempotent producer design would correct me. As a first intuition, you can think of the

Re: New Producer and acks configuration

2015-07-26 Thread Gwen Shapira
Aha! Yes, I was missing the part with the dummy response. Thank you! Gwen On Sun, Jul 26, 2015 at 2:17 PM, Ewen Cheslack-Postava e...@confluent.io wrote: It's different because it changes whether the client waits for the response from the broker at all. Take a look at

[jira] [Resolved] (KAFKA-2362) kafka-consumer-perf-test.sh got a negative result

2015-07-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2362. -- Resolution: Duplicate Assignee: Ewen Cheslack-Postava Fix

Re: New Producer and acks configuration

2015-07-26 Thread Ewen Cheslack-Postava
It's different because it changes whether the client waits for the response from the broker at all. Take a look at NetworkClient.handleCompletedSends, which fills in dummy responses when a response is not expected (and that flag gets set via Sender.produceRequest using acks != 0 as a flag to

Listen interface

2015-07-26 Thread madhavan kumar
hi all, On my ubuntu 14.04 machine, i have a virt-manager/libvirtd private network running. And that has made a virtual network interface, virbr0 with ip 192.168.122.1. in my kafka broker settings, i have set the host.name property to the host name of the machine. When i do netstat -lntp

[jira] [Commented] (KAFKA-2100) Client Error doesn't preserve or display original server error code when it is an unknown code

2015-07-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642179#comment-14642179 ] Ewen Cheslack-Postava commented on KAFKA-2100: -- Option #2 looks good to me as

Re: Listen interface

2015-07-26 Thread madhavan kumar
solved it by removing host.name setting in server.properties.. now kafka is listening on all interfaces, as i expected... thank you all On Mon, Jul 27, 2015 at 8:03 AM, madhavan kumar madhavan020...@gmail.com wrote: hi all, On my ubuntu 14.04 machine, i have a virt-manager/libvirtd private

[jira] [Commented] (KAFKA-1690) new java producer needs ssl support as a client

2015-07-26 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642237#comment-14642237 ] Dong Lin commented on KAFKA-1690: - [~harsha_ch] Thanks much for letting us know. new

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

2015-07-26 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642229#comment-14642229 ] Neha Narkhede commented on KAFKA-2350: -- Few thoughts: bq. 1. Add pause/unpause bq. 2.

[jira] [Comment Edited] (KAFKA-2350) Add KafkaConsumer pause capability

2015-07-26 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642229#comment-14642229 ] Neha Narkhede edited comment on KAFKA-2350 at 7/27/15 3:55 AM:

[jira] [Updated] (KAFKA-2100) Client Error doesn't preserve or display original server error code when it is an unknown code

2015-07-26 Thread David Jacot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-2100: --- Attachment: KAFKA-2100-2.patch Client Error doesn't preserve or display original server error code

[jira] [Created] (KAFKA-2365) Copycat checklist

2015-07-26 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-2365: Summary: Copycat checklist Key: KAFKA-2365 URL: https://issues.apache.org/jira/browse/KAFKA-2365 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-2100) Client Error doesn't preserve or display original server error code when it is an unknown code

2015-07-26 Thread David Jacot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-2100: --- Status: Patch Available (was: Open) Client Error doesn't preserve or display original server error

[jira] [Updated] (KAFKA-2365) Copycat checklist

2015-07-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2365: - Labels: feature (was: ) Description: This covers the development plan

[jira] [Commented] (KAFKA-2100) Client Error doesn't preserve or display original server error code when it is an unknown code

2015-07-26 Thread David Jacot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642296#comment-14642296 ] David Jacot commented on KAFKA-2100: Thank you for your feedback. I just uploaded a

[jira] [Updated] (KAFKA-2365) Copycat checklist

2015-07-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2365: - Issue Type: New Feature (was: Bug) Copycat checklist -

[jira] [Created] (KAFKA-2366) Initial patch for Copycat

2015-07-26 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-2366: Summary: Initial patch for Copycat Key: KAFKA-2366 URL: https://issues.apache.org/jira/browse/KAFKA-2366 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-2367) Add Copycat runtime API

2015-07-26 Thread Ewen Cheslack-Postava (JIRA)
Ewen Cheslack-Postava created KAFKA-2367: Summary: Add Copycat runtime API Key: KAFKA-2367 URL: https://issues.apache.org/jira/browse/KAFKA-2367 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-2364) Improve documentation for contributing to docs

2015-07-26 Thread Aseem Bansal (JIRA)
Aseem Bansal created KAFKA-2364: --- Summary: Improve documentation for contributing to docs Key: KAFKA-2364 URL: https://issues.apache.org/jira/browse/KAFKA-2364 Project: Kafka Issue Type: Task

[jira] [Updated] (KAFKA-2364) Improve documentation for contributing to docs

2015-07-26 Thread Aseem Bansal (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aseem Bansal updated KAFKA-2364: Description: While reading the documentation for kafka 8 I saw some improvements that can be made.

[jira] [Updated] (KAFKA-2364) Improve documentation for contributing to docs

2015-07-26 Thread Aseem Bansal (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aseem Bansal updated KAFKA-2364: Priority: Minor (was: Major) Improve documentation for contributing to docs