Adding a column to the database table
Add a column to the database table to synchronize an existing field from a Kafka topic.
Add a column to the supported database table to synchronize an existing field from a Kafka topic.
Procedure
- On a database node, use ALTER TABLE to add the column to the table.
-
Confirm that the schema change has been pushed to all nodes using nodetool describecluster.
Important: Data synchronization may fail if the schema change is inconsistent across the cluster.
- In the DataStax Apache Kafka Connector configuration file, add the field-to-column definition. See Mapping kafka topics to database tables.