ADO.NET Provider for Apache Kafka

Build 21.0.7940

Tables

The Tables schema collection lists all tables in the database, including views.

Retrieving the Table Listing

To retrieve the Tables schema collection, call the GetSchema method of the ApacheKafkaConnection class.

C#

String connectionString = "User=admin;Password=pass;BootStrapServers=https://localhost:9091;Topic=MyTopic;";

using (ApacheKafkaConnection conn = new ApacheKafkaConnection(connectionString)) {
  conn.Open();
  DataTable databaseSchema = conn.GetSchema("Tables");
  foreach (DataRow row in databaseSchema.Rows) {
    Console.WriteLine(row["TABLE_NAME"]);
  }
}

VB.NET

Dim connectionString As String = "User=admin;Password=pass;BootStrapServers=https://localhost:9091;Topic=MyTopic;"

Using conn As New ApacheKafkaConnection(connectionString)
  conn.Open()
  Dim databaseSchema As DataTable = conn.GetSchema("Tables")
  For Each row As DataRow In databaseSchema.Rows
    Console.WriteLine(row("TABLE_NAME"))
  Next
End Using

Columns Returned

The Tables schema collection returns the following columns.

Column NameData TypeDescription
TABLE_CATALOGSystem.StringThe database that contains the table.
TABLE_SCHEMASystem.StringThe schema that contains the table.
TABLE_NAMESystem.StringThe table name.
TABLE_TYPESystem.StringThe table type.

Copyright (c) 2021 CData Software, Inc. - All rights reserved.
Build 21.0.7940