apache-kafka - インターフェイスからキャプチャされたパケットを kafka にプッシュする

Question

import kafka.serializer.Encoder
import kafka.utils.VerifiableProperties
import org.jnetpcap.packet.PcapPacket
class PcapEncoder(verifiableProperties: VerifiableProperties) extends Encoder[PcapPacket]  { override def toBytes(customMessage: PcapPacket): Array[Byte] = customMessage.transferStateAndDataFrom(PcapPacket : Array[Byte]) }

`これは、jnetpcap ライブラリを使用してキャプチャしたパケットをエンコードして kafka コンシューマに渡すために作成したエンコーダです。しかし、エラーがあります。これはエンコーダーを実装する方法ですか?