Build failed in Jenkins: kafka-trunk-jdk10 #209

See Changes: [jason] KAFKA-7030; Add configuration to disable message down-conversion -- [...truncated 1.58 MB...] kafka.admin.ResetConsumerGroupOffsetTest > testResetOf

Jenkins build is back to normal : kafka-2.0-jdk8 #26

See

Re: Apache Kafka 2.0.0 Release Progress

Hi all, We still have five blockers for 2.0.0. I have moved most of the other JIRAs out, another five issues that include API/doc changes are still marked for 2.0.0. If you think any of the other JIRAs are critical to include in 2.0.0, please update the fix version, mark as blocker and ensure a PR

[jira] [Resolved] (KAFKA-4812) We are facing the same issue as SAMZA-590 for kafka

[ https://issues.apache.org/jira/browse/KAFKA-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4812. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported. Please upgrade

Jenkins build is back to normal : kafka-trunk-jdk8 #2733

See

[jira] [Created] (KAFKA-7057) Consumer stop polling

Moshe Lavi created KAFKA-7057: - Summary: Consumer stop polling Key: KAFKA-7057 URL: https://issues.apache.org/jira/browse/KAFKA-7057 Project: Kafka Issue Type: Bug Components: consumer,

[jira] [Created] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values

Gunnar Morling created KAFKA-7058: - Summary: ConnectSchema#equals() broken for array-typed default values Key: KAFKA-7058 URL: https://issues.apache.org/jira/browse/KAFKA-7058 Project: Kafka

[jira] [Resolved] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6711. --- Resolution: Fixed Reviewer: Matthias J. Sax Fix Version/s: 2.0.0 > GlobalStat

Jenkins build is back to normal : kafka-trunk-jdk10 #210

See

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

See Changes: [rajinisivaram] KAFKA-6711: GlobalStateManagerImpl should not write offsets of in-memory -- [...truncated 468.51 KB...] kafka.controller.PartitionStateMachin

Create account and access KIP

Hi team: Scala administrative client AdminClient is deprecated and replaced by KafkaAdminClient .Some Consumer Group management method should migrate from Scala Admin Client to Java Version . So someone could help me open the permission of KIP and I want to create one to record it .

[jira] [Created] (KAFKA-7059) Offer new constructor on ProducerRecord

Matthias Weßendorf created KAFKA-7059: - Summary: Offer new constructor on ProducerRecord Key: KAFKA-7059 URL: https://issues.apache.org/jira/browse/KAFKA-7059 Project: Kafka Issue Type:

Re: Create account and access KIP

Hello, I saw you have been granted the permission, could you try to create the wiki page? Guozhang On Thu, Jun 14, 2018 at 7:26 AM, 逐风者的祝福 <1878707...@qq.com> wrote: > Hi team: > Scala administrative client AdminClient is deprecated and replaced by > KafkaAdminClient .Some Consumer Group

?????? Create account and access KIP

Yep . it seems ok . thanks -- -- ??: "Guozhang Wang"; : 2018??6??14??(??) 10:56 ??: "dev"; : Re: Create account and access KIP Hello, I saw you have been granted the permission, could you try to create the wiki page? Guoz

[jira] [Resolved] (KAFKA-6975) AdminClient.deleteRecords() may cause replicas unable to fetch from beginning

[ https://issues.apache.org/jira/browse/KAFKA-6975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6975. Resolution: Fixed Fix Version/s: (was: 1.1.1) (was: 1.0.2)

Build failed in Jenkins: kafka-2.0-jdk8 #27

See Changes: [rajinisivaram] KAFKA-6711: GlobalStateManagerImpl should not write offsets of in-memory -- [...truncated 945.78 KB...] kafka.controller.ReplicaStateMachineTest

[jira] [Resolved] (KAFKA-4237) Avoid long request timeout for the consumer

[ https://issues.apache.org/jira/browse/KAFKA-4237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4237. Resolution: Duplicate Duplicate of KAFKA-7050. > Avoid long request timeout for the consumer > ---

[jira] [Resolved] (KAFKA-2837) FAILING TEST: kafka.api.ProducerBounceTest > testBrokerFailure

[ https://issues.apache.org/jira/browse/KAFKA-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2837. Resolution: Fixed Fix Version/s: (was: 0.10.0.0) 2.0.0 This test has

Re: [DISCUSS] KIP-201: Rationalising Policy interfaces

Hi Tom, Just wanted to check what you think about the comments I made in my last message. I think this KIP is a big improvement to our current policy interfaces, and really hope we can get this KIP in. Thanks, Anna On Thu, May 31, 2018 at 3:29 PM, Anna Povzner wrote: > Hi Tom, > > > Thanks for

Jenkins build is back to normal : kafka-trunk-jdk8 #2735

See

Jenkins build is back to normal : kafka-1.0-jdk7 #202

See

Build failed in Jenkins: kafka-trunk-jdk10 #212

See Changes: [github] MINOR: Use KafkaConsumer in GetOffsetShell (#5220) -- [...truncated 1.30 MB...] kafka.server.KafkaApisTest > shouldRespondWithUnsupportedForMessage

Jenkins build is back to normal : kafka-2.0-jdk8 #28

See

Re: Are defaults serde in Kafka streams doing more harm then good ?

2) Pre-registering serdes and data types for Kafka topics as well as state stores could be a good feature to add. 3) For this, we can consider capturing the ClassCastException in serde callers and returns a more informative error. Guozhang On Wed, Jun 13, 2018 at 8:34 PM, Stephane Maarek < step

Jenkins build is back to normal : kafka-1.1-jdk7 #145

See

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

See Changes: [github] MINOR: Use KafkaConsumer in GetOffsetShell (#5220) [github] MINOR: Use ListOffsets request instead of SimpleConsumer in -- [...truncated 477.52 KB..

[jira] [Resolved] (KAFKA-7010) Rename ResourceNameType.ANY to MATCH

[ https://issues.apache.org/jira/browse/KAFKA-7010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-7010. Resolution: Fixed merged the PR to trunk and 2.0 branch. > Rename ResourceNameType.ANY to MATCH >

Re: [DISCUSS] KIP-291: Have separate queues for control requests and data requests

bq. that's a waste of resource if control request rate is low I don't know if control request rate can get to 100,000, likely not. Then using the same bound as that for data requests seems high. On Wed, Jun 13, 2018 at 10:13 PM, Lucas Wang wrote: > Hi Ted, > > Thanks for taking a look at this

Build failed in Jenkins: kafka-trunk-jdk10 #213

See Changes: [github] MINOR: Use ListOffsets request instead of SimpleConsumer in -- [...truncated 1.30 MB...] kafka.server.KafkaApisTest > shouldRespondWithUnsupportedF

Build failed in Jenkins: kafka-0.11.0-jdk7 #379

See Changes: [matthias] KAFKA-6711: GlobalStateManagerImpl should not write offsets of in-memory -- [...truncated 979.90 KB...] kafka.utils.UtilsTest > testUrlSafeBase64

Re: [DISCUSS] KIP-291: Have separate queues for control requests and data requests

Hi Ted, Dong I've updated the KIP by adding a new config, instead of reusing the existing one. Please take another look when you have time. Thanks a lot! Lucas On Thu, Jun 14, 2018 at 2:33 PM, Ted Yu wrote: > bq. that's a waste of resource if control request rate is low > > I don't know if co

[jira] [Created] (KAFKA-7060) Command-line overrides for ConnectDistributed worker properties

Kevin Lafferty created KAFKA-7060: - Summary: Command-line overrides for ConnectDistributed worker properties Key: KAFKA-7060 URL: https://issues.apache.org/jira/browse/KAFKA-7060 Project: Kafka

Jenkins build is back to normal : kafka-trunk-jdk10 #214

See

[DISCUSS] KIP-316: Command-line overrides for ConnectDistributed worker properties

Hi all, I created KIP-316, and I would like to initiate discussion. The KIP is here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-316%3A+Command-line+overrides+for+ConnectDistributed+worker+properties Thanks, Kevin

Jenkins build is back to normal : kafka-0.10.2-jdk7 #213

See

Re: [DISCUSS] KIP-291: Have separate queues for control requests and data requests

Currently in KafkaConfig.scala : val QueuedMaxRequests = 500 It would be good if you can include the default value for this new config in the KIP. Thanks On Thu, Jun 14, 2018 at 4:28 PM, Lucas Wang wrote: > Hi Ted, Dong > > I've updated the KIP by adding a new config, instead of reusing the

Jenkins build is back to normal : kafka-trunk-jdk8 #2737

See

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

See Changes: [jason] KAFKA-6975; Fix replica fetching from non-batch-aligned log start offset -- [...truncated 232.88 KB...] kafka.api.TransactionsTest > testSendOffsets STAR

[jira] [Resolved] (KAFKA-7055) Kafka Streams Processor API allows you to add sinks and processors without parent

[ https://issues.apache.org/jira/browse/KAFKA-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7055. Resolution: Fixed Fix Version/s: 2.0.0 > Kafka Streams Processor API allows you to a

[jira] [Resolved] (KAFKA-6445) Remove deprecated metrics in 2.0

[ https://issues.apache.org/jira/browse/KAFKA-6445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6445. Resolution: Fixed Assignee: Dong Lin (was: Charly Molter) Fix Version/s: (was: