Package io.aiven.commons.kafka.connector.source.impl.csv

Class ExampleCsvClient

java.lang.Object

io.aiven.commons.kafka.connector.source.impl.csv.ExampleCsvClient

public class ExampleCsvClient
extends Object

A "native" client. This client returns lists of native objects and ByteBuffers for specific native keys.

In an actual implementation this would connect to the storage and retrieve data.

Field Summary

Fields

Modifier and Type	Field	Description
String	dataSent	The last key sent.

Constructor Summary

Constructors

Constructor	Description
ExampleCsvClient()	Creates an example client that returns records in 3 batches of 10 records.

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

dataSent

public String dataSent

The last key sent.

Constructor Details

ExampleCsvClient

public ExampleCsvClient()
                 throws IOException

Creates an example client that returns records in 3 batches of 10 records.

Throws:

IOException - if data can not be constructed.