Skip to content

Commit cbb3b9e

Browse files
authored
Update kafka-bend-ingest-kafka.md (#1182)
1 parent 5eec795 commit cbb3b9e

File tree

1 file changed

+49
-2
lines changed

1 file changed

+49
-2
lines changed

docs/en/tutorials/load/kafka-bend-ingest-kafka.md

Lines changed: 49 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,9 +96,56 @@ WARN[0072] Failed to read message from Kafka: context deadline exceeded kafka_b
9696
2024/08/20 15:10:15 ingest 2 rows (1.225576 rows/s), 75 bytes (45.959100 bytes/s)
9797
```
9898

99-
3. In Databend Cloud, verify that the data has been successfully loaded:
99+
3. Connect to Databend Cloud using BendSQL and verify that the data has been successfully loaded:
100100

101-
![alt text](../../../../static/img/documents/tutorials/kafka-6.png)
101+
```bash
102+
Welcome to BendSQL 0.19.2-1e338e1(2024-07-17T09:02:28.323121000Z).
103+
Connecting to tn3ftqihs--eric.gw.aws-us-east-2.default.databend.com:443 with warehouse eric as user cloudapp
104+
Connected to Databend Query v1.2.626-nightly-a055124b65(rust-1.81.0-nightly-2024-08-27T15:49:08.376336236Z)
102105

106+
cloudapp@(eric)/doc> SELECT * FROM databend_topic;
103107

108+
SELECT * FROM databend_topic
104109

110+
-[ RECORD 1 ]-----------------------------------
111+
id: 1
112+
name: Alice
113+
age: 30
114+
-[ RECORD 2 ]-----------------------------------
115+
id: 2
116+
name: Bob
117+
age: 25
118+
```
119+
120+
4. To load the messages in RAW mode, simple run the following command:
121+
122+
```bash
123+
bend-ingest-kafka \
124+
--kafka-bootstrap-servers="localhost:9092" \
125+
--kafka-topic="test-topic" \
126+
--databend-dsn="<your-dsn>" \
127+
--is-json-transform=false
128+
```
129+
130+
You will get a new table in the `doc` database, containing the following rows:
131+
132+
```bash
133+
cloudapp@(eric)/doc> SELECT * FROM test_ingest;
134+
135+
SELECT * FROM test_ingest
136+
137+
-[ RECORD 1 ]-----------------------------------
138+
uuid: 17f9e56e-19ba-4d42-88a0-e16b27815d04
139+
koffset: 0
140+
kpartition: 0
141+
raw_data: {"age":30,"id":1,"name":"Alice"}
142+
record_metadata: {"create_time":"2024-08-27T19:10:45.888Z","key":"","offset":0,"partition":0,"topic":"test-topic"}
143+
add_time: 2024-08-27 19:12:55.081444
144+
-[ RECORD 2 ]-----------------------------------
145+
uuid: 0f57f71a-32ee-4df3-b75e-d123b9a91543
146+
koffset: 1
147+
kpartition: 0
148+
raw_data: {"age":25,"id":2,"name":"Bob"}
149+
record_metadata: {"create_time":"2024-08-27T19:10:52.946Z","key":"","offset":1,"partition":0,"topic":"test-topic"}
150+
add_time: 2024-08-27 19:12:55.081470
151+
```

0 commit comments

Comments
 (0)