@@ -30,13 +30,13 @@ https://github.com/glennfawcett/roachcrib
30
30
``` bash
31
31
32
32
# Start Consumer for Avro
33
- ./bin/kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic student99_pets
33
+ ./bin/kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic student2_pets
34
34
35
35
# List Topics
36
36
./bin/kafka-topics --list --bootstrap-server localhost:9092
37
37
38
38
# Delete Topics
39
- ./bin/kafka-topics --bootstrap-server localhost:9092 --delete --topic student99_pets
39
+ ./bin/kafka-topics --bootstrap-server localhost:9092 --delete --topic student2_pets
40
40
41
41
```
42
42
@@ -67,14 +67,14 @@ CREATE TABLE pets (
67
67
``` sql
68
68
-- Connect to your Database
69
69
--
70
- use student99 ;
70
+ use student2 ;
71
71
72
72
-- Create CHANGEFEED... set topic_prefix to your database name!!
73
73
--
74
74
CREATE CHANGEFEED FOR TABLE pets
75
- INTO ' kafka://10.142.0.109 :9092?topic_prefix=student99_ '
75
+ INTO ' kafka://10.142.0.33 :9092?topic_prefix=student2_ '
76
76
WITH updated, resolved= ' 20s' ,
77
- confluent_schema_registry = ' http://10.142.0.109 :8081' ,
77
+ confluent_schema_registry = ' http://10.142.0.33 :8081' ,
78
78
format = ' experimental_avro' ,
79
79
diff,
80
80
schema_change_policy= backfill;
@@ -87,9 +87,9 @@ CREATE CHANGEFEED FOR TABLE pets
87
87
``` bash
88
88
# # Start a Avro consumer in a SHELL on the kafka cluster
89
89
# #
90
- ssh -i ./bench-ssh-key bench@35.243.252.96
90
+ ssh -i ./bench-ssh-key bench@glenn-confluent-0001.roachprod.crdb.io
91
91
cd confluent-5.5.0
92
- ./bin/kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic student99_pets
92
+ ./bin/kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic student2_pets
93
93
```
94
94
95
95
** From another window, connect to the database and insert some values into the table you created:**
0 commit comments