Hi

You could use Port — Elixir v1.20.2 with the stdout option of https://maxwells-daemon.io/

I have this proof of concept code that might get you started

defmodule MaxwellListener do
  use GenServer

  # Adjust the command to include the full executable path if necessary
  @command "maxwell"
  @args [
    "--user='maxwell'",
    "--password='XXXXXX'",
    "--host='127.0.0.1'",
    "--filter='exclude: *.*, include: holdsport.users, include: holdsport.teams_users'",
    "--producer=stdout"
  ]

  def start_link(opts \\ []) do
    GenServer.start_link(__MODULE__, :ok, opts)
  end

  def init(:ok) do
    command_with_args = Enum.join([@command | @args], " ")
    options = [:binary, :exit_status]
    port = Port.open({:spawn, command_with_args}, options)
    {:ok, %{port: port}}
  end

  def handle_info({port, {:data, data}}, state) do
    process_output(data)
    {:noreply, state}
  end

  def handle_info({:EXIT, _port, _reason}, state) do
    # Handle port exit
    {:stop, :normal, state}
  end

  defp process_output(data) do
    data
    |> String.trim_trailing()
    |> Jason.decode!(keys: :atoms)
    |> handle()
  end

  defp handle(%{table: "teams_users", data: %{users_id: user_id}}) do
    IO.inspect(user_id, label: "User ID")
  end

  defp handle(d) do
    IO.inspect(d, limit: :infinity)
  end
end