kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tamas Cserveny (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams
Date Thu, 25 Jan 2018 13:25:00 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339204#comment-16339204

Tamas Cserveny commented on KAFKA-6483:

This is one spot which does not use upcast to ExtendedSerializer:  


public <K, V> void send(final String topic,
final K key,
final V value,
final Integer partition,
final Long timestamp,
final Serializer<K> keySerializer,
final Serializer<V> valueSerializer) {
final byte[] keyBytes = keySerializer.serialize(topic, key);
final byte[] valBytes = valueSerializer.serialize(topic, value);

final ProducerRecord<byte[], byte[]> serializedRecord =
new ProducerRecord<>(topic, partition, timestamp, keyBytes, valBytes);

> Support ExtendedSerializer in Kafka Streams
> -------------------------------------------
>                 Key: KAFKA-6483
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6483
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>    Affects Versions:
>            Reporter: Tamas Cserveny
>            Assignee: Dale Peakall
>            Priority: Major
>             Fix For:
> KIP-82 introduced the concept of message headers and introduced an ExtendedDeserializer
interface that allowed a Deserializer to access those message headers.
> Change Kafka Streams to support the use of ExtendedSerializer to provide compatibility
with Kafka Clients that use the new header functionality.

This message was sent by Atlassian JIRA

View raw message