Upgraded to Kafka 1.1.0

Author: pgraff

labs/01-Verify-Installation/docker-compose.yml

@@ -1,12 +1,13 @@
 version: '2'
 services:
-  zookeeper:
-    image: zookeeper:3.4.9
-  kafka:
-    image: wurstmeister/kafka:0.10.1.1
-    environment:
-      HOSTNAME_COMMAND: "echo $HOSTNAME"
-      KAFKA_ADVERTISED_PORT: 9092
-      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
-    depends_on:
-      - zookeeper
+    zookeeper:
+        image: wurstmeister/zookeeper:3.4.6
+        ports:
+          - 2181:2181
+    kafka:
+        image: wurstmeister/kafka:1.1.0
+        environment:
+            KAFKA_LISTENERS: PLAINTEXT://kafka:9092
+            KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
+        ports:
+            - 9092:9092

labs/01-Verify-Installation/hello-world-kafka.md

@@ -13,7 +13,7 @@ In this lab, you will install Kafka with Docker and verify it is working by crea
 
 One of the easiest way to get started with Kafka is through the use of [Docker](https://www.docker.com). Docker allows the deployment of applications inside software containers which are self-contained execution environments with their own isolated CPU, memory, and network resources. [Install Docker by following the directions appropriate for your operating system.](https://www.docker.com/products/overview) Make sure that you can run both the `docker` and `docker-compose` command from the terminal.
 
-## Alias
+## [OPTIONAL] Alias
 
 Because we use docker and docker-compose, the commands to run the kafka CLI are absurdly long.
 
@@ -28,9 +28,9 @@ You may want to alias these commands. In Linux and Mac, you can simply create al
 E.g., say you run bash, you can open the `~/.bash_profile` file with your favorite editor and enter something like this:
 
 ```
-  alias ktopics='docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-topics.sh'
-  alias kconsole-producer='docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-console-producer.sh'
-  alias kconsole-consumer='docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-console-consumer.sh'
+  alias ktopics='docker-compose exec kafka /opt/kafka/bin/kafka-topics.sh'
+  alias kconsole-producer='docker-compose exec kafka /opt/kafka/bin/kafka-console-producer.sh'
+  alias kconsole-consumer='docker-compose exec kafka /opt/kafka/bin/kafka-console-consumer.sh'
 ```
 
 When you start new shells, you can now simply run:
@@ -72,28 +72,28 @@ You are now running inside the container and all the commands should work (and a
 3. Open an additional terminal window in the lesson directory, `lelabs/01-Verify-Installation`. We are going to create a topic called `helloworld` with a single partition and one replica:
 
   ```
-  $ docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic helloworld
+  $ docker-compose exec kafka /opt/kafka/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic helloworld
   ```
 
 4. You can now see the topic that was just created with the `--list` flag:
 
   ```
-  $ docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-topics.sh --list --zookeeper zookeeper:2181
+  $ docker-compose exec kafka /opt/kafka/bin/kafka-topics.sh --list --zookeeper zookeeper:2181
   helloworld
   ```
 
 5. Normally you would use the Kafka API from within your application to produce messages but Kafka comes with a command line _producer_ client that can be used for testing purposes. Each line from standard input will be treated as a separate message. Type a few messages and leave the process running.
 
   ```
-  $ docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-console-producer.sh --broker-list kafka:9092 --topic helloworld
+  $ docker-compose exec kafka /opt/kafka/bin/kafka-console-producer.sh --broker-list kafka:9092 --topic helloworld
   Hello world!
   Welcome to Kafka.
   ```
 
 6. Open another terminal window in the lesson directory. In this window, we can use Kafka's command line _consumer_ that will output the messages to standard out.
 
   ```
-  $ docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic helloworld --from-beginning
+  $ docker-compose exec kafka /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic helloworld --from-beginning
   Hello world!
   Welcome to Kafka.
   ```

labs/02-Publish-And-Subscribe/consumer/pom.xml

@@ -12,7 +12,7 @@
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka-clients</artifactId>
-            <version>0.10.1.1</version>
+            <version>1.1.0</version>
         </dependency>
         <dependency>
             <groupId>com.google.guava</groupId>

labs/02-Publish-And-Subscribe/docker/docker-compose.yml

@@ -1,17 +1,17 @@
 version: '2'
 services:
   zookeeper:
-    image: zookeeper:3.4.9
+    image: wurstmeister/zookeeper:3.4.6
     ports:
       - 2181:2181
   kafka:
-    image: wurstmeister/kafka:0.10.1.1
+    image: wurstmeister/kafka:1.1.0
     ports:
       - 9092:9092
       - 7203:7203
     environment:
       KAFKA_ADVERTISED_HOST_NAME: [INSERT IP ADDRESS HERE]
-      KAFKA_ADVERTISED_PORT: 9092
+#      KAFKA_ADVERTISED_HOST_NAME: localhost
       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
     depends_on:
       - zookeeper

labs/02-Publish-And-Subscribe/producer.md

@@ -24,17 +24,17 @@ All the directory references in this lab is relative to where you expended the l
     version: '2'
     services:
       zookeeper:
-        image: zookeeper:3.4.9
+        image: wurstmeister/zookeeper:3.4.6
         ports:
           - 2181:2181
       kafka:
-        image: wurstmeister/kafka:0.10.1.1
+        image: wurstmeister/kafka:1.1.0
         ports:
           - 9092:9092
           - 7203:7203
         environment:
           KAFKA_ADVERTISED_HOST_NAME: [INSERT IP ADDRESS HERE]
-          KAFKA_ADVERTISED_PORT: 9092
+    #      KAFKA_ADVERTISED_HOST_NAME: localhost
           KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
         depends_on:
           - zookeeper
@@ -56,9 +56,9 @@ All the directory references in this lab is relative to where you expended the l
         inet6 fe80::cc8a:c5ff:fe43:b670%awdl0 prefixlen 64 scopeid 0x8
         inet6 fe80::7df6:ec93:ffea:367a%utun0 prefixlen 64 scopeid 0xa
     ```
-
     In this case, the IP address to use is `10.0.1.4`. Make sure you *do not* use `127.0.0.1` because that will not work correctly.
 
+
     On Windows, you can use the following command:
 
     ```
@@ -80,6 +80,10 @@ All the directory references in this lab is relative to where you expended the l
 
     Save the `docker-compose.yml` file after making this modification.
 
+      > We have noticed on some configurations of Windows and Linux that the use of `KAFKA_ADVERTISED_HOST_NAME` does not work properly (the Kafka clients can't connect).
+      > We've not found the source of this problem, but in many of the cases we've seen, the use of `localhost` instead of the host IP may work.
+      > Note though, that the use of `localhost` prevents you from running multiple Kafka brokers on the same machine.
+
 1. Start the Kafka and Zookeeper processes using Docker Compose:
 
     ```
@@ -89,14 +93,14 @@ All the directory references in this lab is relative to where you expended the l
 1. Open an additional terminal window in the lesson directory, `docker/`. We are going to create two topics that will be used in the Producer program. Run the following commands:
 
     ```
-    $ docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic user-events
-    $ docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic global-events
+    $ docker-compose exec kafka /opt/kafka/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic user-events
+    $ docker-compose exec kafka /opt/kafka/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic global-events
     ```
 
 1. List the topics to double check they were created without any issues.
 
     ```
-    $ docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-topics.sh --list --zookeeper zookeeper:2181
+    $ docker-compose exec kafka /opt/kafka/bin/kafka-topics.sh --list --zookeeper zookeeper:2181
     global-events
     user-events
     ```
@@ -107,7 +111,7 @@ All the directory references in this lab is relative to where you expended the l
     <dependency>
         <groupId>org.apache.kafka</groupId>
         <artifactId>kafka-clients</artifactId>
-        <version>0.10.1.1</version>
+        <version>1.1.0</version>
     </dependency>
     <dependency>
         <groupId>com.google.guava</groupId>

labs/02-Publish-And-Subscribe/producer/pom.xml

@@ -12,7 +12,7 @@
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka-clients</artifactId>
-            <version>0.10.1.1</version>
+            <version>1.1.0</version>
         </dependency>
         <dependency>
             <groupId>com.google.guava</groupId>

labs/04-Implement-Topics-And-Partitions/device-monitor/pom.xml

@@ -12,7 +12,7 @@
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka-clients</artifactId>
-            <version>0.10.1.1</version>
+            <version>1.1.0</version>
         </dependency>
         <dependency>
             <groupId>com.google.guava</groupId>

labs/04-Implement-Topics-And-Partitions/docker/docker-compose.yml

@@ -11,6 +11,7 @@ services:
       - 7203:7203
     environment:
       KAFKA_ADVERTISED_HOST_NAME: [INSERT IP ADDRESS HERE]
+#      KAFKA_ADVERTISED_HOST_NAME: localhost
       KAFKA_ADVERTISED_PORT: 9092
       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
     depends_on:

labs/04-Implement-Topics-And-Partitions/heartbeat-simulator/pom.xml

@@ -12,7 +12,7 @@
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka-clients</artifactId>
-            <version>0.10.1.1</version>
+            <version>1.1.0</version>
         </dependency>
         <dependency>
             <groupId>com.google.guava</groupId>

labs/04-Implement-Topics-And-Partitions/topics-and-partitions.md

@@ -43,8 +43,8 @@ $ docker-compose up
 Next we'll simply create the topics. Open a new terminal in the `docker` directory.
 
 ```
-$ docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic device-heartbeat
-$ docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic device-event
+$ docker-compose exec kafka /opt/kafka/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic device-heartbeat
+$ docker-compose exec kafka /opt/kafka/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic device-event
 ```
 
 ## Build and run the device simulator
@@ -87,7 +87,7 @@ To see the messages, let's run our usual console consumer. In a new terminal `cd
 
 ```
 $ cd docker
-$ docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic device-heartbeat
+$ docker-compose exec kafka /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic device-heartbeat
 ```
 
 After a few seconds you should start to see heartbeat messages being produced. E.g.:
@@ -151,7 +151,7 @@ In a new shell, go to the `docker` directory.
 
 ```
 $ cd docker
-$ docker-compose exec kafka /opt/kafka_2.11-0.10.1.1/bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic device-event
+$ docker-compose exec kafka /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic device-event
 ```
 
 It may take some time before you see online or offline messages (see the device simulator and you'll see the randomness of the heartbeat production).