msvitok77

package main

import (
	"fmt"
	"io/ioutil"
	"log"
	"net/http"
)

const (

msvitok77

import urllib.request
from datetime import datetime, timedelta

import sys

server = ''


def delete_one(what):
    """Deletes one logstash storage"""

msvitok77

import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

public class MQTTConsumer {
    public static void main(String[] args) {

        String topic = "sah/+/#";

msvitok77

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.ByteArraySerializer;
import org.apache.kafka.common.serialization.Serdes;
import org.apache.kafka.common.serialization.StringSerializer;
import org.apache.kafka.streams.KafkaStreams;
import org.apache.kafka.streams.kstream.KStream;
import org.apache.kafka.streams.kstream.KStreamBuilder;
import org.apache.kafka.streams.kstream.KTable;