Code

Add KafkaMessageQueue#148

Code

Merged

nerdai merged 29 commits intomainrun-llama/llama_deploy:mainfrom nerdai/kafkarun-llama/llama_deploy:nerdai/kafkaCopy head branch name to clipboardJul 21, 2024

+1,497-3

Commits

Commits on Jul 21, 2024

• Bump certifi from 2024.6.2 to 2024.7.4 (#108)

  

  dependabot[bot]

  authored and

  nerdai

  committed
  e87aa69

• Bump certifi from 2024.6.2 to 2024.7.4 (#108)

  

  dependabot[bot]

  authored and

  nerdai

  committed
  29f33de

• kafka dep aiokafka

  nerdai

  committed
  fa11f21

• start KafkaMessageQueue and impl create topic

  nerdai

  committed
  c91c7a8

• todo note

  nerdai

  committed
  9298490

• register consumer

  nerdai

  committed
  0497f10

• return start consuming callble

  nerdai

  committed
  cf9f92d

• bug

  nerdai

  committed
  43a8970

• clean up delete topics

  nerdai

  committed
  cced712

• functional

  nerdai

  committed
  13f5d5d

• add argparse for convenient testing

  nerdai

  committed
  bcf96ed

• start unit tests

  nerdai

  committed
  97f4029

• add some unit tests

  nerdai

  committed
  c5cd60d

• mock producer.start

  nerdai

  committed
  1dc64a8

• start examples

  nerdai

  committed
  7d62f54

• wip

  nerdai

  committed
  5830f4d

• clean up

  nerdai

  committed
  17338d7

• lint

  nerdai

  committed
  0c5ea51

• update readme

  nerdai

  committed
  ba46a07

• docker compose

  nerdai

  committed
  8e51a7b

• wip

  nerdai

  committed
  1bed39c

• wip

  nerdai

  committed
  b89cb91

• working docker example

  nerdai

  committed
  2017ba7

• nit

  nerdai

  committed
  dc71038

• update pyproject

  nerdai

  committed
  678c6f6

• docs

  nerdai

  committed
  083b926

• nit in README

  nerdai

  committed
  c9126e5

• cr

  nerdai

  committed
  c51b6ae

• cr

  nerdai

  committed
  71e15aa