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)