nowfound

AI · January 12, 2024

CK

Confluent Kafka support added to FastStream v0.4.0rc0

FastStream - https://github.com/airtai/faststream, a stream processing framework, already supports Kafka stream processing using the aiokafka library, as well as other brokers such as Redis, RabbitMQ, and NATS. Responding to popular demand, the latest 0.4.0rc0 version introduces support for Kafka stream processing using Confluent Kafka's Python library - https://github.com/confluentinc/confluent-kafka-python. Please take a look at it and let us know what you think: https://faststream.airt.ai/0.4/confluent/ Wondering why and how…

Alternatives

What it does

In the maker’s words, at launch

FastStream - https://github.com/airtai/faststream, a stream processing framework, already supports Kafka stream processing using the aiokafka library, as well as other brokers such as Redis, RabbitMQ, and NATS. Responding to popular demand, the latest 0.4.0rc0 version introduces support for Kafka stream processing using Confluent Kafka's Python library - https://github.com/confluentinc/confluent-kafka-python. Please take a look at it and let us know what you think: https://faststream.airt.ai/0.4/confluent/ Wondering why and how we created FastStream? We've documented that in this short blog post - https://dev.to/airtai/how-we-deprecated-two-successful-projects-and-joined-forces-to-create-an-even-more-successful-one-3lon

Does the same job

all alternatives →
  • A1
    AutoMQ 1.5.0 released, providing native Iceberg support for Kafka2025 · github.com · ▲9

    AutoMQ is a fully open-source, next-generation Kafka built on top of S3. Version 1.5.0 is a very important release. In March of this year, Confluent officially launched the commercial capability of Tableflow. Now, with the AutoMQ open-source software, you can also experience this killer feature. Simply put, for Kafka streaming data, AutoMQ can automatically store it in S3 in Iceberg Table format, so you no longer need to manage Flink Jobs and Spark Jobs yourself to perform ETL operations and convert Kafka data into table format. We believe this will be the new paradigm for Kafka stream data…

  • RT
    Real Time Stream Processing Startup2020 · ▲6

    We are working on a product which makes stream processing easy for data analysts and data scientists. It’s a higher level alternative to Flink, Kafka Streams and Spark Streams. As well as making stream processing simpler, we also felt that lots of people were building these AWS stream processing platforms based on Kafka and something like Flink so wanted to offer this as a service. We would welcome any input on the space or approach: Home page: http://Timeflow.systems Demo: https://youtu.be/fGfgBaHXOkE

  • Upstash2022 · ▲233

    Serverless data platform for Redis and Kafka

  • Streambench – Native Mac Client for Kafka and NATS23d ago · streambench.app · ▲13

    When building Hookie, I worked with NATS Jetstream a lot. While you can do everything using the CLI, I prefer the feeling of a nice GUI better. So I built one.

  • KS
    KQ – Simple Job Queue for Python Using Kafka2016 · github.com · ▲116
  • GD
    Goka – distributed stream processing library for Kafka written in Go2017 · github.com · ▲105

More ai this month

the category →
  • I trained a 125M model to autocomplete piano on-device▲598

    I trained a 125M-parameter transformer to autocomplete piano performances in real time (~108 notes/sec on an iPhone 15). The idea is basically GitHub Copilot or Tabnine, except instead of prompting it with code, you prompt it by playing a few notes on a MIDI piano. The model then continues what you played, entirely on-device. The app is free if anyone wants to try it. Happy to answer questions about the model, training, Core ML, or the many things that didn't work.

    AI · 17d ago · simedw.com

  • Astute▲585

    Automate your B2B brand going viral, with new media creators

    AI · 18d ago · company-app.joinastute.com

  • Grok Bot▲547

    AI teammates that you can give real work to

    AI · 25d ago · x.ai

  • Needle2: 14MB agentic LLM for phones, wearables, smart home and robots▲537

    Hey HN, Henry from Cactus here! We previously released Cactus Needle, a 14MB agentic LLM for tool call, device use, and structured extraction for phones, wearables, smart homes, small robots and microcontrollers. We got really great feedback here, and have now incorporated the suggestions to release Needle 2. The whole model is a single 14MB binary that runs a full session in 28MB of RAM; 45m parameters at 2bit compression. Needle hits 500 tokens/sec decode speed on a Raspberry Pi 5, sits between 400-1,500 tokens/sec on VR devices like Meta Quest 3S and Apple Vision Pro, and ranges…

    AI · 27d ago · cactuscompute.com

  • Clara AI SDR▲460

    Turn website visitors into qualified pipeline

    AI · 19d ago · clarasdr.ai

  • Kane CLI▲446

    Natural language browser & mobile app tests from terminal

    AI · 24d ago · testmuai.com

Launched alongside, January 2024

the whole month →