The CData ADO.NET Provider for Apache Kafka implements two ADO.NET interfaces you can use to retrieve data from Apache Kafka: ApacheKafkaDataAdapter and ApacheKafkaDataReader objects. Whereas ApacheKafkaDataAdapter objects retrieve a single result set of all the data that matches a query, ApacheKafkaDataReader objects fetch data in subset increments as needed.

Using the ApacheKafkaDataReader

The ApacheKafkaDataReader retrieves data faster than the ApacheKafkaDataAdapter because it can retrieve data in pages. As you read data from the ApacheKafkaDataReader, it periodically requests the next page of results from the data source, if required. This causes results to be returned at a faster rate. The following example selects all the columns from the SampleTable_1 table:

C#

string connectionString = "User=admin;Password=pass;BootStrapServers=localhost:9091";

using (ApacheKafkaConnection connection = new ApacheKafkaConnection(connectionString)) {
  ApacheKafkaCommand cmd = new ApacheKafkaCommand("SELECT * FROM SampleTable_1", connection);
  
  ApacheKafkaDataReader rdr = cmd.ExecuteReader();

  while (rdr.Read()) {
    Console.WriteLine(String.Format("\t{0} --> \t\t{1}", rdr["Id"], rdr["Column1"]));
  }
}

VB.NET

Dim connectionString As String = "User=admin;Password=pass;BootStrapServers=localhost:9091"

Using connection As New ApacheKafkaConnection(connectionString)
  Dim cmd As New ApacheKafkaCommand("SELECT * FROM SampleTable_1", connection)

  Dim rdr As ApacheKafkaDataReader = cmd.ExecuteReader()

  While rdr.Read()
    Console.WriteLine([String].Format(vbTab & "{0} --> " & vbTab & vbTab & "{1}", rdr("Id"), rdr("Column1")))
  End While
End Using