Versions Compared

Old Version 14

changes.mady.by.user Chia-Ping Tsai

Saved on

compared with

New Version 15

changes.mady.by.user Chia-Ping Tsai

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  1. backward compatibility
    kafka.common.MessageReader implementations can keep working without recompilation. 
  2. deprecation
    1. kafka.common.MessageReader is deprecated
    2. the method init(InputStream inputStream, Properties props) is deprecated and replacement is configure(InputStream inputStream, Map<String, ?> configs)
  3. migration plan: users have address following changes to complete code migration
    1. change inheritance from kafka.common.MessageReader to org.apache.kafka.client.tooltools.RecordReader
    2. change method signature from init(InputStream inputStream, Properties props) to configure(InputStream inputStream, Map<String, ?> configs)
    3. change method signature from readMessage to readRecord

...

  1. support the usage of Serializers (from Juma): this support could complicate the configs, since users have to define both MessageReader and serializer. It seems to me the mechanism of MessageReader should include serialization.
  2. move RecordReader to "org.apache.kafka.common": "org.apache.kafka.common" does not allow to import code from "org.apache.kafka.clients.producer". However, the tool-related interface should be able to access producer, consumer and admin code.