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:  

 

org.apache.kafka.streams.processor.internals.RecordCollectorImpl:
{code:java}
@Override
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) {
checkForException();
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);
 {code}

> 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: 0.11.0.0
>            Reporter: Tamas Cserveny
>            Assignee: Dale Peakall
>            Priority: Major
>             Fix For: 0.11.0.0
>
>
> 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
(v7.6.3#76005)

Mime
View raw message