<commit_before>#!/usr/bin/env python
import threading, logging, time

from kafka import KafkaConsumer


class Consumer(threading.Thread):
    daemon = True

    def run(self):
        #consumer = KafkaConsumer(bootstrap_servers='10.100.198.220:9092',
        consumer = KafkaConsumer(bootstrap_servers='10.0.2.15:9092',
                                 auto_offset_reset='earliest')
        consumer.subscribe(['voltha-heartbeat'])

        for message in consumer:
            print (message)


def main():
    threads = [
        Consumer()
    ]

    for t in threads:
        t.start()

    time.sleep(3000)

if __name__ == "__main__":
    logging.basicConfig(
        format='%(asctime)s.%(msecs)s:%(name)s:%(thread)d:%(levelname)s:%(process)d:%(message)s',
        level=logging.INFO
        )
    main()
<commit_msg>Update IP address of kafka consumer<commit_after>#!/usr/bin/env python
import threading, logging, time

from kafka import KafkaConsumer


class Consumer(threading.Thread):
    daemon = True

    def run(self):
        consumer = KafkaConsumer(bootstrap_servers='10.100.198.220:9092',
        #consumer = KafkaConsumer(bootstrap_servers='10.0.2.15:9092',
                                 auto_offset_reset='earliest')
        consumer.subscribe(['voltha-heartbeat'])

        for message in consumer:
            print (message)


def main():
    threads = [
        Consumer()
    ]

    for t in threads:
        t.start()

    time.sleep(3000)

if __name__ == "__main__":
    logging.basicConfig(
        format='%(asctime)s.%(msecs)s:%(name)s:%(thread)d:%(levelname)s:%(process)d:%(message)s',
        level=logging.INFO
        )
    main()

{'fraction_non_alphanumeric': 0.1342925659472422, 'fraction_numerical': 0.03477218225419664, 'mean_word_length': 2.5969827586206895, 'pattern_counts': {'":': 2, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 4, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 2, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '1166871', 'n_tokens_mistral': 573, 'n_tokens_neox': 522, 'n_words': 95}