# Step 2: Select Database
db = client['qdrant_kafka']