|
182 | 182 | },
|
183 | 183 | "outputs": [],
|
184 | 184 | "source": [
|
185 |
| - "!curl -sSOL https://downloads.apache.org/kafka/2.7.2/kafka_2.13-2.7.2.tgz\n", |
186 |
| - "!tar -xzf kafka_2.13-2.7.2.tgz" |
| 185 | + "!curl -sSOL https://dlcdn.apache.org/kafka/3.1.0/kafka_2.13-3.1.0.tgz\n", |
| 186 | + "!tar -xzf kafka_2.13-3.1.0.tgz" |
187 | 187 | ]
|
188 | 188 | },
|
189 | 189 | {
|
|
203 | 203 | },
|
204 | 204 | "outputs": [],
|
205 | 205 | "source": [
|
206 |
| - "!./kafka_2.13-2.7.2/bin/zookeeper-server-start.sh -daemon ./kafka_2.13-2.7.2/config/zookeeper.properties\n", |
207 |
| - "!./kafka_2.13-2.7.2/bin/kafka-server-start.sh -daemon ./kafka_2.13-2.7.2/config/server.properties\n", |
| 206 | + "!./kafka_2.13-3.1.0/bin/zookeeper-server-start.sh -daemon ./kafka_2.13-3.1.0/config/zookeeper.properties\n", |
| 207 | + "!./kafka_2.13-3.1.0/bin/kafka-server-start.sh -daemon ./kafka_2.13-3.1.0/config/server.properties\n", |
208 | 208 | "!echo \"Waiting for 10 secs until kafka and zookeeper services are up and running\"\n",
|
209 |
| - "!sleep 10\n" |
| 209 | + "!sleep 10" |
210 | 210 | ]
|
211 | 211 | },
|
212 | 212 | {
|
|
249 | 249 | },
|
250 | 250 | "outputs": [],
|
251 | 251 | "source": [
|
252 |
| - "!./kafka_2.13-2.7.2/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --replication-factor 1 --partitions 1 --topic susy-train\n", |
253 |
| - "!./kafka_2.13-2.7.2/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --replication-factor 1 --partitions 2 --topic susy-test\n" |
| 252 | + "!./kafka_2.13-3.1.0/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --replication-factor 1 --partitions 1 --topic susy-train\n", |
| 253 | + "!./kafka_2.13-3.1.0/bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --replication-factor 1 --partitions 2 --topic susy-test\n" |
254 | 254 | ]
|
255 | 255 | },
|
256 | 256 | {
|
|
270 | 270 | },
|
271 | 271 | "outputs": [],
|
272 | 272 | "source": [
|
273 |
| - "!./kafka_2.13-2.7.2/bin/kafka-topics.sh --describe --bootstrap-server 127.0.0.1:9092 --topic susy-train\n", |
274 |
| - "!./kafka_2.13-2.7.2/bin/kafka-topics.sh --describe --bootstrap-server 127.0.0.1:9092 --topic susy-test\n" |
| 273 | + "!./kafka_2.13-3.1.0/bin/kafka-topics.sh --describe --bootstrap-server 127.0.0.1:9092 --topic susy-train\n", |
| 274 | + "!./kafka_2.13-3.1.0/bin/kafka-topics.sh --describe --bootstrap-server 127.0.0.1:9092 --topic susy-test\n" |
275 | 275 | ]
|
276 | 276 | },
|
277 | 277 | {
|
|
722 | 722 | },
|
723 | 723 | "outputs": [],
|
724 | 724 | "source": [
|
725 |
| - "!./kafka_2.13-2.7.2/bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group testcg\n" |
| 725 | + "!./kafka_2.13-3.1.0/bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group testcg\n" |
726 | 726 | ]
|
727 | 727 | },
|
728 | 728 | {
|
|
0 commit comments