Re: [DISCUSS] KIP-250 Add Support for Quorum-based Producer Acknowledgment

Hi Guozhang, Are you proposing changing semantic of ack=all to acknowledge message only after all replicas (not all ISRs, which is what Kafka currently is doing) have committed the message? This is equivalent to setting min.isr=number of replicas, which makes ack=all much stricter than what Kafka

Re: [DISCUSS] KIP-250 Add Support for Quorum-based Producer Acknowledgment

Hey Guozhang, I don't have very detailed design. But I have some high level idea that can probably work. Here is how it looks like: - When controller needs to do leadership movement - Controller sends a request asking the brokers involved in the migration to use acks=[isr_set] and wait for res

[jira] [Resolved] (KAFKA-6515) Add toString() method to kafka connect Field class

[ https://issues.apache.org/jira/browse/KAFKA-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6515. Resolution: Fixed Fix Version/s: 1.2.0 > Add toString() method to kafka connect Field

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

See