|
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