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 消费者。但是我有错误,这是实现编码器的方法吗?