You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Konstantine Karantasis (Jira)" <ji...@apache.org> on 2020/06/11 00:51:00 UTC

[jira] [Updated] (KAFKA-8938) Connect - Improve Memory Allocations During Struct Validation

     [ https://issues.apache.org/jira/browse/KAFKA-8938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Konstantine Karantasis updated KAFKA-8938:
------------------------------------------
    Fix Version/s: 2.5.1
                   2.6.0

> Connect - Improve Memory Allocations During Struct Validation
> -------------------------------------------------------------
>
>                 Key: KAFKA-8938
>                 URL: https://issues.apache.org/jira/browse/KAFKA-8938
>             Project: Kafka
>          Issue Type: Improvement
>          Components: KafkaConnect
>            Reporter: Auston McReynolds
>            Priority: Minor
>             Fix For: 2.6.0, 2.5.1
>
>
> Summary: Struct value validation in Kafka Connect can be optimized to avoid creating an Iterator when the expectedClasses list is of size 1. This is a meaningful enhancement for high throughput connectors.
> Stack Trace from the Couchbase Kafka Connector:
>  * java.util.Collections.singletonIterator(Object)
>  * java.util.Collections$SingletonList.iterator()
>  * org.apache.kafka.connect.data.ConnectSchema.validateValue(String, Schema, Object)
>  * org.apache.kafka.connect.data.Struct.put(Field, Object)
>  * org.apache.kafka.connect.data.Struct.put(String, Object)
>  * com.couchbase.connect.kafka.handler.source.DefaultSchemaSourceHandler.buildValue(SourceHandlerParams, CouchbaseSourceRecord$Builder)



--
This message was sent by Atlassian Jira
(v8.3.4#803005)