ProtobufConsumerRecordToTableWriterAdapter

java.lang.Object

io.deephaven.kafka.ingest.ProtobufConsumerRecordToTableWriterAdapter

All Implemented Interfaces:: ConsumerRecordToTableWriterAdapter

@ScriptApi
public class ProtobufConsumerRecordToTableWriterAdapter
extends Object
implements ConsumerRecordToTableWriterAdapter

Converts a consumer record containing ProtoBuf serialized objects to a Deephaven row.

Nested Class Summary

Nested Classes

Modifier and Type Class Description

static class ProtobufConsumerRecordToTableWriterAdapter.Builder
A builder to map key and value fields to table columns.

Method Summary

Modifier and Type	Method	Description
`void`	`consumeRecord(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)`	Consume a Kafka record, producing zero or more rows in the output.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- consumeRecord
  
  public void consumeRecord(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record) throws IOException
  
  Description copied from interface: ConsumerRecordToTableWriterAdapter
  
  Consume a Kafka record, producing zero or more rows in the output.
  
  Specified by:
  
  consumeRecord in interface ConsumerRecordToTableWriterAdapter
  
  Parameters:
  
  record - the record received from KafkaConsumer.poll(Duration).
  
  Throws:
  
  IOException - if there was an error writing to the output table