Send_Kafka_RunInfo.py

# This file is part of the ISIS IBEX application.
# Copyright (C) 2012-2021 Science & Technology Facilities Council.
# All rights reserved.
#
# This program is distributed in the hope that it will be useful.
# This program and the accompanying materials are made available under the
# terms of the Eclipse Public License v1.0 which accompanies this distribution.
# EXCEPT AS EXPRESSLY SET FORTH IN THE ECLIPSE PUBLIC LICENSE V1.0, THE PROGRAM
# AND ACCOMPANYING MATERIALS ARE PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES
# OR CONDITIONS OF ANY KIND.  See the Eclipse Public License v1.0 for more details.
#
# You should have received a copy of the Eclipse Public License v1.0
# along with this program; if not, you can obtain a copy from
# https://www.eclipse.org/org/documents/epl-v10.php or
# http://opensource.org/licenses/eclipse-1.0.php
from confluent_kafka import Producer

SERVER = "itachi.isis.cclrc.ac.uk:9092"
TOPIC = "MAPSTEST_runInfo"
producer = Producer({"bootstrap.servers": SERVER})

def send_flatBuffer(data):
    """
    Send data to kafka
    Args:
        data: Flatbuffer Data to send to Kafka
        instrument: The instrument to send data for
    """
    producer.produce(TOPIC, data)
    producer.flush()