Skip to content

Commit a3f1cff

Browse files
idanasulin2706idanasulin2706
committed
fix examples + set debuggers for each
1 parent 04a51d9 commit a3f1cff

File tree

13 files changed

+151
-3
lines changed

13 files changed

+151
-3
lines changed

‎.vscode/launch.json‎

Lines changed: 151 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,160 @@
22
"version": "0.2.0",
33
"configurations": [
44
{
5-
"name": "Python: Main",
5+
"name": "kafka-python: Apache",
66
"type": "debugpy",
77
"request": "launch",
8-
"program": "main.py",
8+
"program": "${workspaceFolder}/examples/kafkapy/apache.py",
99
"console": "integratedTerminal",
10-
"justMyCode": true
10+
"env": {
11+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
12+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
13+
"SUPERSTREAM_DISABLED": "false",
14+
"SUPERSTREAM_DEBUG": "true"
15+
}
16+
},
17+
{
18+
"name": "kafka-python: Aiven",
19+
"type": "debugpy",
20+
"request": "launch",
21+
"program": "${workspaceFolder}/examples/kafkapy/aiven.py",
22+
"console": "integratedTerminal",
23+
"env": {
24+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
25+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
26+
"SUPERSTREAM_DISABLED": "false",
27+
"SUPERSTREAM_DEBUG": "true"
28+
}
29+
},
30+
{
31+
"name": "kafka-python: Confluent",
32+
"type": "debugpy",
33+
"request": "launch",
34+
"program": "${workspaceFolder}/examples/kafkapy/confluent.py",
35+
"console": "integratedTerminal",
36+
"env": {
37+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
38+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
39+
"SUPERSTREAM_DISABLED": "false",
40+
"SUPERSTREAM_DEBUG": "true"
41+
}
42+
},
43+
{
44+
"name": "kafka-python: MSK",
45+
"type": "debugpy",
46+
"request": "launch",
47+
"program": "${workspaceFolder}/examples/kafkapy/msk.py",
48+
"console": "integratedTerminal",
49+
"env": {
50+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
51+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
52+
"SUPERSTREAM_DISABLED": "false",
53+
"SUPERSTREAM_DEBUG": "true"
54+
}
55+
},
56+
{
57+
"name": "aiokafka: Apache",
58+
"type": "debugpy",
59+
"request": "launch",
60+
"program": "${workspaceFolder}/examples/aiokafka/apache.py",
61+
"console": "integratedTerminal",
62+
"env": {
63+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
64+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
65+
"SUPERSTREAM_DISABLED": "false",
66+
"SUPERSTREAM_DEBUG": "true"
67+
}
68+
},
69+
{
70+
"name": "aiokafka: Aiven",
71+
"type": "debugpy",
72+
"request": "launch",
73+
"program": "${workspaceFolder}/examples/aiokafka/aiven.py",
74+
"console": "integratedTerminal",
75+
"env": {
76+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
77+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
78+
"SUPERSTREAM_DISABLED": "false",
79+
"SUPERSTREAM_DEBUG": "true"
80+
}
81+
},
82+
{
83+
"name": "aiokafka: Confluent",
84+
"type": "debugpy",
85+
"request": "launch",
86+
"program": "${workspaceFolder}/examples/aiokafka/confluent.py",
87+
"console": "integratedTerminal",
88+
"env": {
89+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
90+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
91+
"SUPERSTREAM_DISABLED": "false",
92+
"SUPERSTREAM_DEBUG": "true"
93+
}
94+
},
95+
{
96+
"name": "aiokafka: MSK",
97+
"type": "debugpy",
98+
"request": "launch",
99+
"program": "${workspaceFolder}/examples/aiokafka/msk.py",
100+
"console": "integratedTerminal",
101+
"env": {
102+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
103+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
104+
"SUPERSTREAM_DISABLED": "false",
105+
"SUPERSTREAM_DEBUG": "true"
106+
}
107+
},
108+
{
109+
"name": "confluent-kafka: Apache",
110+
"type": "debugpy",
111+
"request": "launch",
112+
"program": "${workspaceFolder}/examples/confluent_kafka/apache.py",
113+
"console": "integratedTerminal",
114+
"env": {
115+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
116+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
117+
"SUPERSTREAM_DISABLED": "false",
118+
"SUPERSTREAM_DEBUG": "true"
119+
}
120+
},
121+
{
122+
"name": "confluent-kafka: Aiven",
123+
"type": "debugpy",
124+
"request": "launch",
125+
"program": "${workspaceFolder}/examples/confluent_kafka/aiven.py",
126+
"console": "integratedTerminal",
127+
"env": {
128+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
129+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
130+
"SUPERSTREAM_DISABLED": "false",
131+
"SUPERSTREAM_DEBUG": "true"
132+
}
133+
},
134+
{
135+
"name": "confluent-kafka: Confluent",
136+
"type": "debugpy",
137+
"request": "launch",
138+
"program": "${workspaceFolder}/examples/confluent_kafka/confluent.py",
139+
"console": "integratedTerminal",
140+
"env": {
141+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
142+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
143+
"SUPERSTREAM_DISABLED": "false",
144+
"SUPERSTREAM_DEBUG": "true"
145+
}
146+
},
147+
{
148+
"name": "confluent-kafka: MSK",
149+
"type": "debugpy",
150+
"request": "launch",
151+
"program": "${workspaceFolder}/examples/confluent_kafka/msk.py",
152+
"console": "integratedTerminal",
153+
"env": {
154+
"SUPERSTREAM_TOPICS_LIST": "test-topic,test-topic-1,test-topic-2,test-topic-3",
155+
"SUPERSTREAM_LATENCY_SENSITIVE": "false",
156+
"SUPERSTREAM_DISABLED": "false",
157+
"SUPERSTREAM_DEBUG": "true"
158+
}
11159
}
12160
]
13161
}

examples/aiokafka/aiven_kafka_example.py renamed to examples/aiokafka/aiven.py

File renamed without changes.

examples/asynciokafka.py renamed to examples/aiokafka/apache.py

File renamed without changes.

examples/aiokafka/confluent_kafka_example.py renamed to examples/aiokafka/confluent.py

File renamed without changes.

examples/aiokafka/msk_producer_example.py renamed to examples/aiokafka/msk.py

File renamed without changes.

examples/confluent_kafka/aiven_kafka_example.py renamed to examples/confluent_kafka/aiven.py

File renamed without changes.

examples/confluent.py renamed to examples/confluent_kafka/apache.py

File renamed without changes.

examples/confluent_kafka/confluent_kafka_example.py renamed to examples/confluent_kafka/confluent.py

File renamed without changes.

examples/confluent_kafka/msk_kafka_example.py renamed to examples/confluent_kafka/msk.py

File renamed without changes.

examples/kafkapy/aiven_kafka_example.py renamed to examples/kafkapy/aiven.py

File renamed without changes.

0 commit comments

Comments
 (0)