Changes

Apache Avro with Kafka

3 bytes added, 11:38, 2 April 2019

→‎Partition keys

<source lang="java">

props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, org.apache.kafka.common.serialization.LongSerializer.class);

</presource>

A fenti módosítással már csak a value sémáját fogja elküldeni a Kafka-ba írás előtt a producer a séma regiszternek.

• ← Older edit
• Newer edit →

Adam

Bureaucrat, administrator

7,540

edits