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

See Changes: [mjsax] KAFKA-6659: Improve error message if state store is not found (#4732) [mjsax] MINOR: Rolling bounce upgrade fixed broker system test (#4690) [github] KAFKA-6611: PART I, Use JMXTool in Simp

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

See Changes: [ismael] KAFKA-6683; Ensure producer state not mutated prior to append (#4755) [github] MINOR: Java 9/10 fixes, gradle and minor deps update (#4725) -- Start

[jira] [Created] (KAFKA-6706) NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrormaker producer after 1.0 broker upgrade

Di Shang created KAFKA-6706: --- Summary: NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrormaker producer after 1.0 broker upgrade Key: KAFKA-6706 URL: https://issues.apache.org/jira/browse/KAFKA-6706 Project:

Build failed in Jenkins: kafka-1.0-jdk7 #177

See Changes: [jason] KAFKA-6683; Ensure producer state not mutated prior to append (#4755) -- [...truncated 373.51 KB...] kafka.log.BrokerCompressionTest > testBrokerSideComp

[jira] [Created] (KAFKA-6707) The value of Type.LONG should be *L

JieFang.He created KAFKA-6707: - Summary: The value of Type.LONG should be *L Key: KAFKA-6707 URL: https://issues.apache.org/jira/browse/KAFKA-6707 Project: Kafka Issue Type: Improvement

Re: [VOTE] KIP-257 - Configurable Quota Management

Thanks for the KIP, Rajini +1 (non binding) -- Edoardo Comar IBM Message Hub IBM UK Ltd, Hursley Park, SO21 2JN From: Ted Yu To: dev@kafka.apache.org Date: 22/03/2018 22:17 Subject:Re: [VOTE] KIP-257 - Configurable Quota Manage

Re: [DISCUSS] KIP-253: Support in-order message delivery with partition expansion

Hi Jun, thanks for your great reply, even though I only managed to throw a few sentences in, because of time last time. I think you are starting to understand me pretty well. There is still some minor things that need to be flattened out. I already had these points previously but I try to rep

[jira] [Created] (KAFKA-6708) Review JavaDocs and Documentation with regards to Serde Useage

Bill Bejeck created KAFKA-6708: -- Summary: Review JavaDocs and Documentation with regards to Serde Useage Key: KAFKA-6708 URL: https://issues.apache.org/jira/browse/KAFKA-6708 Project: Kafka Iss

Re: [VOTE] KIP-257 - Configurable Quota Management

+1 (non binding), thanks Rajini On Fri, Mar 23, 2018 at 9:38 AM, Edoardo Comar wrote: > Thanks for the KIP, Rajini > > +1 (non binding) > -- > > Edoardo Comar > > IBM Message Hub > > IBM UK Ltd, Hursley Park, SO21 2JN > > > > From: Ted Yu > To:

[jira] [Resolved] (KAFKA-6703) MirrorMaker cannot make progress when any matched topic from a whitelist regexp has -1 leader

[ https://issues.apache.org/jira/browse/KAFKA-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari resolved KAFKA-6703. --- Resolution: Not A Bug It turned out I forgot to set proper replication factor for {{__consume

[jira] [Resolved] (KAFKA-6680) Fix config initialization in DynamicBrokerConfig

[ https://issues.apache.org/jira/browse/KAFKA-6680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6680. -- Resolution: Fixed Fix Version/s: (was: 1.2.0) 1.1.0 > Fix config initializ

[jira] [Resolved] (KAFKA-6676) System tests do not handle ZK chroot properly with SCRAM

[ https://issues.apache.org/jira/browse/KAFKA-6676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6676. -- Resolution: Fixed Fix Version/s: 1.1.0 > System tests do not handle ZK chroot properly with SCRAM

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

See Changes: [github] MINOR: Fix encoder config to make DynamicBrokerReconfigurationTest -- Started by an SCM change [EnvInject] - Loading node environment variables. Buil

Build failed in Jenkins: kafka-1.1-jdk7 #98

See -- [...truncated 1.90 MB...] org.apache.kafka.streams.integration.RestoreIntegrationTest > shouldProcessDataFromStoresWithLoggingDisabled PASSED org.apache.kafka.streams.integration.Res

Build failed in Jenkins: kafka-trunk-jdk7 #3283

See Changes: [github] MINOR: Fix encoder config to make DynamicBrokerReconfigurationTest -- Started by an SCM change [EnvInject] - Loading node environment variables. Buil

Re: [DISCUSS] KIP-222 - Add "describe consumer group" to KafkaAdminClient

Hi everyone, There has been some changes at the API level to support: * Request every node to list consumer groups: ``` public class ListConsumerGroupsResult { final KafkaFuture>>> future; //... } ``` * Request coordinators to describe/list Offset/delete consumer groups: ``` public c

[VOTE] KIP-235 Add DNS alias support for secured connection

Hi, I would like to start a vote for KIP-235 https://cwiki.apache.org/confluence/display/KAFKA/KIP-235%3A+Add+DNS+alias+support+for+secured+connection This is a proposition to add an option for reverse dns lookup of bootstrap.servers hosts, allowing the use of dns aliases on clusters using SASL

Build failed in Jenkins: kafka-1.1-jdk7 #99

See Changes: [rajinisivaram] MINOR: Fix encoder config to make DynamicBrokerReconfigurationTest -- [...truncated 1.90 MB...] org.apache.kafka.streams.integration.RestoreInteg

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

Regarding the flexibility question, has someone tried to dig up the discussion of the new consumer APIs when they were being written? I vaguely recall these exact questions about using APIs vs configs and flexibility vs bloating the API surface area having already been discussed. (Not that we shoul

[VOTE] 1.1.0 RC4

Hello Kafka users, developers and client-developers, This is the fifth candidate for release of Apache Kafka 1.1.0. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75957546 A few highlights: * Significant Controller improvements (much faster and session expiration edge cases fi

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

Hi Ewen, Yeah, I mentioned KAFKA-2391 where some of this was discussed. Jay was against having timeouts in the methods at the time. However, as Jason said offline, we did end up with a timeout parameter in `poll`. Ismael On Fri, Mar 23, 2018 at 4:26 PM, Ewen Cheslack-Postava wrote: > Regarding

Build failed in Jenkins: kafka-1.1-jdk7 #100

See -- [...truncated 1.68 MB...] org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldOnlyReadRecordsWhereEarliestSpecifiedWithInvalidCommittedOffsets

Build failed in Jenkins: kafka-trunk-jdk7 #3284

See Changes: [jqin] KAFKA-6612: Added logic to prevent increasing partition counts during -- Started by an SCM change [EnvInject] - Loading node environment variables. Bui

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

See Changes: [jqin] KAFKA-6612: Added logic to prevent increasing partition counts during -- Started by an SCM change [EnvInject] - Loading node environment variables. Bui

Re: [VOTE] 1.1.0 RC4

When I ran test suite, I got one failure: kafka.api.PlaintextConsumerTest > testAsyncCommit FAILED java.lang.AssertionError: expected:<5> but was:<1> at org.junit.Assert.fail(Assert.java:88) at org.junit.Assert.failNotEquals(Assert.java:834) at org.junit.Assert.assertEq