Re: [DISCUSS] KIP-232: Detect outdated metadata by adding ControllerMetadataEpoch field

Hey Jun, Jason, Thanks for all the comments. Could you see if you can give +1 for the KIP? I am open to make further improvements for the KIP. Thanks, Dong On Tue, Jan 23, 2018 at 3:44 PM, Dong Lin wrote: > Hey Jun, Jason, > > Thanks much for all the review! I will open the voting thread. > >

[jira] [Resolved] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-6378. --- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 4424 [https://github.com/

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

See Changes: [damian.guy] KAFKA-6378 KStream-GlobalKTable null KeyValueMapper handling -- [...truncated 164.77 KB...] kafka.server.ReplicaManagerTest > testReceiveOutOfOrde

[jira] [Created] (KAFKA-6507) NPE in KafkaStatusBackingStore

Itay Cohai created KAFKA-6507: - Summary: NPE in KafkaStatusBackingStore Key: KAFKA-6507 URL: https://issues.apache.org/jira/browse/KAFKA-6507 Project: Kafka Issue Type: Bug Components:

[jira] [Created] (KAFKA-6508) Look into optimizing StreamPartitionAssignor StandbyTask Assignment

Bill Bejeck created KAFKA-6508: -- Summary: Look into optimizing StreamPartitionAssignor StandbyTask Assignment Key: KAFKA-6508 URL: https://issues.apache.org/jira/browse/KAFKA-6508 Project: Kafka

[jira] [Created] (KAFKA-6509) Add additional tests for validating store restoration completes before Topology is intitalized

Bill Bejeck created KAFKA-6509: -- Summary: Add additional tests for validating store restoration completes before Topology is intitalized Key: KAFKA-6509 URL: https://issues.apache.org/jira/browse/KAFKA-6509

[jira] [Created] (KAFKA-6510) WARN: Fail to send SSL Close message

John Chu created KAFKA-6510: --- Summary: WARN: Fail to send SSL Close message Key: KAFKA-6510 URL: https://issues.apache.org/jira/browse/KAFKA-6510 Project: Kafka Issue Type: Bug Affects Versions

[jira] [Resolved] (KAFKA-5142) KIP-145 - Expose Record Headers in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5142. -- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 431

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

See Changes: [me] KAFKA-4930: Enforce set of legal characters for connector names -- [...truncated 409.15 KB...] kafka.utils.CoreUtilsTest > testAtomicGetOrUpdate STARTED

Build failed in Jenkins: kafka-trunk-jdk9 #348

See Changes: [me] KAFKA-4930: Enforce set of legal characters for connector names -- [...truncated 1.45 MB...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[1

[jira] [Created] (KAFKA-6511) Connect header parser incorrectly parses arrays

Arjun Satish created KAFKA-6511: --- Summary: Connect header parser incorrectly parses arrays Key: KAFKA-6511 URL: https://issues.apache.org/jira/browse/KAFKA-6511 Project: Kafka Issue Type: Bug

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

See Changes: [me] KAFKA-4930: Enforce set of legal characters for connector names -- [...truncated 3.44 MB...] kafka.security.auth.SimpleAclAuthorizerTest > testAclManage

Build failed in Jenkins: kafka-trunk-jdk9 #349

See Changes: [me] KAFKA-5142: Add Connect support for message headers (KIP-145) -- [...truncated 1.45 MB...] kafka.controller.PartitionLeaderElectionAlgorithmsTest > testC

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

See -- Started by an SCM change Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H24 (ubuntu xenial) in workspace

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

See Changes: [me] KAFKA-5142: Add Connect support for message headers (KIP-145) -- [...truncated 407.53 KB...] kafka.controller.ControllerIntegrationTest > testAutoPrefe

[jira] [Resolved] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

[ https://issues.apache.org/jira/browse/KAFKA-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6138. Resolution: Fixed > Simplify StreamsBuilder#addGlobalStore > ---

[DISCUSS] KIP-252: Extend ACLs to allow filtering based on ip ranges and subnets

Hey everybody, following a brief inital discussion a couple of days ago on this list I'd like to get a discussion going on KIP-252 which would allow specifying ip ranges and subnets for the -allow-host and --deny-host parameters of the acl tool. The KIP can be found at https://cwiki.apache.org/co

[jira] [Created] (KAFKA-6512) Java Producer: Excessive memory usage with compression enabled

Kyle Tinker created KAFKA-6512: -- Summary: Java Producer: Excessive memory usage with compression enabled Key: KAFKA-6512 URL: https://issues.apache.org/jira/browse/KAFKA-6512 Project: Kafka Iss

RE: Excessive Memory Usage with Compression enabled and possible resolutions

Ismael, I have filed https://issues.apache.org/jira/browse/KAFKA-6512 for this issue. I could not find a target version field. Let me know if you need any additional information. I'm new to this project so hopefully the format is what you were looking for. - Kyle -Original Message-

Build failed in Jenkins: kafka-trunk-jdk9 #350

See Changes: [jason] KAFKA-6275: Add DeleteGroups API (KIP-229) (#4479) [mjsax] KAFKA-6138 Simplify StreamsBuilder#addGlobalStore (#4430) -- [...truncated 1.46 MB...] kafk

Re: Excessive Memory Usage with Compression enabled and possible resolutions

Hi Kyle, Are you interested in submitting a pull request? Ismael On Wed, Jan 31, 2018 at 3:00 PM, Kyle Tinker wrote: > Ismael, > > I have filed https://issues.apache.org/jira/browse/KAFKA-6512 for this > issue. I could not find a target version field. Let me know if you need > any additional

RE: Excessive Memory Usage with Compression enabled and possible resolutions

Ismael: I'd be interested in submitting a PR for #1 & #2, but I think the fix for #4 would be better suited to someone with a fuller understanding of Kafka. I may also need a bit of help with how to structure the unit tests, if any are needed. Do you have any recommendations for what unit test

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

See

[jira] [Created] (KAFKA-6513) New Connect header support doesn't define `converter.type` property correctly

Randall Hauch created KAFKA-6513: Summary: New Connect header support doesn't define `converter.type` property correctly Key: KAFKA-6513 URL: https://issues.apache.org/jira/browse/KAFKA-6513 Project:

[jira] [Created] (KAFKA-6514) Add API version as a tag for the RequestsPerSec metric

Allen Wang created KAFKA-6514: - Summary: Add API version as a tag for the RequestsPerSec metric Key: KAFKA-6514 URL: https://issues.apache.org/jira/browse/KAFKA-6514 Project: Kafka Issue Type: Im

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

See Changes: [jason] KAFKA-6275: Add DeleteGroups API (KIP-229) (#4479) [mjsax] KAFKA-6138 Simplify StreamsBuilder#addGlobalStore (#4430) -- [...truncated 235.77 KB...]

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

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H27 (ubuntu xenial) in workspace

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

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H27 (ubuntu xenial) in workspace

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

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H27 (ubuntu xenial) in workspace

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

See Changes: [github] MINOR: Fix brokerId passed to metrics reporters (#4497) -- [...truncated 412.11 KB...] kafka.server.epoch.LeaderEpochFileCacheTest > shouldNotResetE

Jenkins build is back to normal : kafka-trunk-jdk9 #351

See

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

See Changes: [github] MINOR: Fix brokerId passed to metrics reporters (#4497) -- [...truncated 3.47 MB...] kafka.utils.json.JsonValueTest > testDecodeString STARTED kafka