Commit cb54fb91 authored by Hines, Jesse's avatar Hines, Jesse
Browse files

Fix Kafka not persisting data

parent 656ead90

docker-compose.yml

+1 −1
Original line number Diff line number Diff line
@@ -184,7 +184,7 @@ services: 
      - KAFKA_SOCKET_SEND_BUFFER_BYTES=102400

      - KAFKA_SOCKET_RECEIVE_BUFFER_BYTES=102400

      - KAFKA_SOCKET_REQUEST_MAX_BYTES=104857600

      - KAFKA_LOG_DIRS=/tmp/kraft-combined-logs

      - KAFKA_LOG_DIRS=/var/lib/kafka/data

      - KAFKA_NUM_PARTITIONS=1

      - KAFKA_NUM_RECOVERY_THREADS_PER_DATA_DIR=1

      - KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1

simulation_server/util/kafka.py

+3 −1
Original line number Diff line number Diff line
@@ -23,7 +23,9 @@ def get_kafka_producer(config = {}): 




def get_kafka_consumer(*topics, config = {}):

    return Consumer({**_get_kafka_config(), **config})

    consumer = Consumer({**_get_kafka_config(), **config})

    consumer.subscribe(list(topics))

    return consumer





def get_kafka_admin(config = {}):