ronaknnathani

#!/bin/bash
ansible-playbook ./kafka.yml --extra-vars "zookeeper_tag=class2_zookeeper kafka_tag=class_kafka" --tags "install"
ansible-playbook ./kafka.yml --extra-vars "zookeeper_tag=class2_zookeeper kafka_tag=class_kafka" --tags "start"

ronaknnathani

---
key_pair: ronak-nathani
instance_type: t2.medium
region: us-west-2
security_group_id: sg-19127861
num_instances: 2
subnet_id: subnet-3a78835f
tag_key_vals:
  Name: ronak-ec2-role
  class: kafka

ronaknnathani

#!/usr/bin/env python

# Using new TCP connection for each HTTP request

import os
import json
import time
import logging
import requests
from requests.auth import HTTPBasicAuth

ronaknnathani

#!/usr/bin/env python

# Using same TCP connection for all HTTP requests

import os
import json
import time
import logging
import requests
from requests.auth import HTTPBasicAuth

ronaknnathani

#!/usr/bin/env python
import requests
import logging
import time
import os
import json
from requests.auth import HTTPBasicAuth

logging.basicConfig(level=logging.DEBUG)
start_time = time.time()

ronaknnathani

#!/usr/bin/env python
import requests
import logging
import time
import os
import json
from requests.auth import HTTPBasicAuth

logging.basicConfig(level=logging.DEBUG)
start_time = time.time()