pvsune

#!/usr/bin/env python
import logging
import os
import threading
import time
from multiprocessing import Process
from queue import Queue

from confluent_kafka import Consumer