flyaruu

[package]
name = "test-mqtt-std"
version = "0.1.0"
edition = "2021"

[dependencies]
embedded-tls = { git="https://github.com/drogue-iot/embedded-tls"}
rand = "0.8.5"
tokio = { version = "1.38.0", features = ["macros", "net", "rt", "rt-multi-thread", "tokio-macros", "time"] }
embedded-io-adapters = { version = "0.6", features = ["tokio-1"] }

flyaruu

use std::{
    net::{Ipv4Addr, SocketAddr},
    time::Duration, str::from_utf8,
};

use embedded_io_adapters::tokio_1::FromTokio;
use rust_mqtt::{
    client::{client::MqttClient, client_config::ClientConfig},
    packet::v5::reason_codes::ReasonCode,
    utils::rng_generator::CountingRng,

flyaruu

package hapi;

import ca.uhn.fhir.context.FhirContext;
import ca.uhn.fhir.interceptor.api.Hook;
import ca.uhn.fhir.interceptor.api.Pointcut;
import ca.uhn.fhir.rest.api.DeleteCascadeModeEnum;
import ca.uhn.fhir.rest.api.MethodOutcome;
import ca.uhn.fhir.rest.api.server.RequestDetails;
import ca.uhn.fhir.rest.client.api.IGenericClient;
import ca.uhn.fhir.rest.client.api.ServerValidationModeEnum;

flyaruu

import java.time.Duration;

import org.junit.Test;

import io.r2dbc.pool.ConnectionPool;
import io.r2dbc.pool.ConnectionPoolConfiguration;
import io.r2dbc.postgresql.PostgresqlConnectionConfiguration;
import io.r2dbc.postgresql.PostgresqlConnectionFactory;
import io.r2dbc.spi.Connection;
import reactor.core.publisher.Flux;

flyaruu

[lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason-43871f6a-e485-4617-85a4-ce1709608a86-StreamThread-1] DEBUG org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason-43871f6a-e485-4617-85a4-ce1709608a86-StreamThread-1-consumer, groupId=lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason] Committed offset 1306 for partition KNBSB-develop-sportlinkkernel-COMPETITIONTYPEATTRIBUTE-0
[lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason-43871f6a-e485-4617-85a4-ce1709608a86-StreamThread-1] DEBUG org.apache.kafka.streams.processor.internals.AssignedStreamsTasks - stream-thread [lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason-43871f6a-e485-4617-85a4-ce1709608a86-StreamThread-1] Committed active task 4_0 per user request in
[lowlevel-KNBSB-develop-generation-190620b-lowlevel-classseason-43871f6a-e485-4617-85a4-ce1709608a86-StreamThread-1] DEBUG org.apache.kafka.streams.processor.

flyaruu

Topologies:
   Sub-topology: 0
    Source: sportlinkkernel-ORGANIZATIONCOMMUNICATION_src (topics: [KNBSB-develop-sportlinkkernel-ORGANIZATIONCOMMUNICATION])
      --> sportlinkkernel-ORGANIZATIONCOMMUNICATION_transform
    Processor: sportlinkkernel-ORGANIZATIONCOMMUNICATION_transform (stores: [])
      --> sportlinkkernel-ORGANIZATIONCOMMUNICATION
      <-- sportlinkkernel-ORGANIZATIONCOMMUNICATION_src
    Source: .FACILITYORG_src (topics: [KNBSB-develop-generation-190620-lowlevel-FACILITYORG])
      --> .FACILITYORG_transform
    Processor: sportlinkkernel-ORGANIZATIONCOMMUNICATION (stores: [sportlinkkernel-ORGANIZATIONCOMMUNICATION])

flyaruu

package com.dexels.kafka.streams.remotejoin.ranged;

import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import java.util.function.BiFunction;

import org.apache.kafka.streams.KeyValue;
import org.apache.kafka.streams.kstream.Predicate;
import org.apache.kafka.streams.processor.AbstractProcessor;