Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions .gitignore
Original file line number Diff line number Diff line change
@@ -1,2 +1,3 @@
node_modules/
**/Gemfile.lint.lock
.claude/
4 changes: 1 addition & 3 deletions .lostconf.yml
Original file line number Diff line number Diff line change
@@ -1,8 +1,6 @@
# lostconf configuration
# Exclude symlinked directories to avoid duplicate/false positives
# v2.4 and v2.5 are symlinks to v2.6
# v2.5 is a symlink to v2.6
exclude:
- v2.4-non-rails
- v2.4-rails
- v2.5-non-rails
- v2.5-rails
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
# Karafka example applications

[![Build Status](https://github.com/karafka/example-app/actions/workflows/ci.yml/badge.svg)](https://github.com/karafka/example-app/actions/workflows/ci.yml)
[![Build Status](https://github.com/karafka/example-apps/actions/workflows/ci.yml/badge.svg)](https://github.com/karafka/example-apps/actions/workflows/ci.yml)
[![Join the chat at https://slack.karafka.io](https://raw.githubusercontent.com/karafka/misc/master/slack.svg)](https://slack.karafka.io)

This repository contains example applications using [Karafka framework](https://github.com/karafka/karafka
) to receive messages from [Apache Kafka](http://kafka.apache.org/) with integrated [WaterDrop gem](https://github.com/karafka/waterdrop) to send messages to Kafka and the [Karafka Web UI](https://github.com/karafka/karafka-web) for Karafka processes management.

To run those applications locally start Apacke Kafka with the included `docker-compose.yml` and follow instructions from the sub-READMEs.
To run those applications locally start Apache Kafka with the included `docker-compose.yml` and follow instructions from the sub-READMEs.

## Applications available

Expand Down
1 change: 0 additions & 1 deletion v2.4-non-rails

This file was deleted.

1 change: 0 additions & 1 deletion v2.4-rails

This file was deleted.

48 changes: 24 additions & 24 deletions v2.6-non-rails/Gemfile.lock
Original file line number Diff line number Diff line change
Expand Up @@ -37,59 +37,59 @@ GEM
i18n (1.15.2)
concurrent-ruby (~> 1.0)
io-console (0.8.2)
json (2.20.0)
karafka (2.5.9)
karafka-core (>= 2.5.6, < 2.6.0)
karafka-rdkafka (>= 0.24.0)
waterdrop (>= 2.8.14, < 3.0.0)
json (2.21.2)
karafka (2.6.0)
karafka-core (>= 2.6.2, < 2.7.0)
karafka-rdkafka (>= 0.28.0)
waterdrop (>= 2.10.2, < 3.0.0)
zeitwerk (~> 2.3)
karafka-core (2.5.13)
karafka-core (2.6.2)
karafka-rdkafka (>= 0.20.0)
logger (>= 1.6.0)
karafka-rdkafka (0.27.2)
karafka-rdkafka (0.28.0)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-rdkafka (0.27.2-aarch64-linux-gnu)
karafka-rdkafka (0.28.0-aarch64-linux-gnu)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-rdkafka (0.27.2-aarch64-linux-musl)
karafka-rdkafka (0.28.0-aarch64-linux-musl)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-rdkafka (0.27.2-arm64-darwin)
karafka-rdkafka (0.28.0-arm64-darwin)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-rdkafka (0.27.2-x86_64-linux-gnu)
karafka-rdkafka (0.28.0-x86_64-linux-gnu)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-rdkafka (0.27.2-x86_64-linux-musl)
karafka-rdkafka (0.28.0-x86_64-linux-musl)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-testing (2.6.0)
karafka (>= 2.5.0, < 2.6.0)
waterdrop (>= 2.8.0)
karafka-web (0.11.6)
karafka-testing (2.6.1)
karafka (>= 2.6.0.rc2, < 2.7.0)
waterdrop (>= 2.10.0)
karafka-web (1.0.0)
erubi (~> 1.4)
karafka (>= 2.5.2, < 2.6.0)
karafka-core (>= 2.5.0, < 2.6.0)
roda (~> 3.69, >= 3.69)
karafka (>= 2.6.0, < 2.7.0)
karafka-core (>= 2.6.2, < 2.7.0)
roda (>= 3.100, < 4.0)
tilt (~> 2.0)
logger (1.7.0)
mini_portile2 (2.8.9)
Expand All @@ -106,7 +106,7 @@ GEM
reline (0.6.3)
io-console (~> 0.5)
rexml (3.4.4)
roda (3.105.0)
roda (3.106.0)
rack
rspec (3.13.2)
rspec-core (~> 3.13.0)
Expand All @@ -123,15 +123,15 @@ GEM
rspec-support (3.13.7)
securerandom (0.4.1)
simplecov (1.0.3)
tilt (2.7.0)
tilt (2.8.0)
tzinfo (2.0.6)
concurrent-ruby (~> 1.0)
uri (1.1.1)
waterdrop (2.10.2)
waterdrop (2.10.3)
karafka-core (>= 2.5.12, < 3.0.0)
karafka-rdkafka (>= 0.24.0)
zeitwerk (~> 2.3)
zeitwerk (2.8.2)
zeitwerk (2.8.3)

PLATFORMS
aarch64-linux-gnu
Expand Down Expand Up @@ -160,4 +160,4 @@ DEPENDENCIES
simplecov

BUNDLED WITH
2.7.2
4.0.16
4 changes: 2 additions & 2 deletions v2.6-non-rails/README.md
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
# Karafka 2.5 non Rails example application
# Karafka 2.6 non Rails example application

This is an example application which uses:

- [Karafka framework](https://github.com/karafka/karafka) `2.5` to receive messages from [Apache Kafka](http://kafka.apache.org/) server
- [Karafka framework](https://github.com/karafka/karafka) `2.6` to receive messages from [Apache Kafka](http://kafka.apache.org/) server
- [Karafka Web UI](https://github.com/karafka/karafka-web) for Karafka processes management
- [WaterDrop gem](https://github.com/karafka/waterdrop) to send messages back to Kafka
- [Karafka-Testing](https://github.com/karafka/testing) provides RSpec helpers, to make testing of Karafka consumers much easier
Expand Down
54 changes: 27 additions & 27 deletions v2.6-rails/Gemfile.lock
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ GEM
date (3.5.1)
diff-lcs (1.6.2)
drb (2.2.3)
erb (6.0.4)
erb (6.0.7)
erubi (1.13.1)
ffi (1.17.4)
ffi (1.17.4-aarch64-linux-gnu)
Expand All @@ -108,64 +108,64 @@ GEM
rdoc (>= 4.0.0)
reline (>= 0.4.2)
json (2.21.2)
karafka (2.5.9)
karafka-core (>= 2.5.6, < 2.6.0)
karafka-rdkafka (>= 0.24.0)
waterdrop (>= 2.8.14, < 3.0.0)
karafka (2.6.0)
karafka-core (>= 2.6.2, < 2.7.0)
karafka-rdkafka (>= 0.28.0)
waterdrop (>= 2.10.2, < 3.0.0)
zeitwerk (~> 2.3)
karafka-core (2.5.13)
karafka-core (2.6.2)
karafka-rdkafka (>= 0.20.0)
logger (>= 1.6.0)
karafka-rdkafka (0.27.2)
karafka-rdkafka (0.28.0)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-rdkafka (0.27.2-aarch64-linux-gnu)
karafka-rdkafka (0.28.0-aarch64-linux-gnu)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-rdkafka (0.27.2-aarch64-linux-musl)
karafka-rdkafka (0.28.0-aarch64-linux-musl)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-rdkafka (0.27.2-arm64-darwin)
karafka-rdkafka (0.28.0-arm64-darwin)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-rdkafka (0.27.2-x86_64-linux-gnu)
karafka-rdkafka (0.28.0-x86_64-linux-gnu)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-rdkafka (0.27.2-x86_64-linux-musl)
karafka-rdkafka (0.28.0-x86_64-linux-musl)
ffi (~> 1.17.1)
json (> 2.0)
logger
mini_portile2 (~> 2.6)
rake (> 12)
karafka-testing (2.6.0)
karafka (>= 2.5.0, < 2.6.0)
waterdrop (>= 2.8.0)
karafka-web (0.11.6)
karafka-testing (2.6.1)
karafka (>= 2.6.0.rc2, < 2.7.0)
waterdrop (>= 2.10.0)
karafka-web (1.0.0)
erubi (~> 1.4)
karafka (>= 2.5.2, < 2.6.0)
karafka-core (>= 2.5.0, < 2.6.0)
roda (~> 3.69, >= 3.69)
karafka (>= 2.6.0, < 2.7.0)
karafka-core (>= 2.6.2, < 2.7.0)
roda (>= 3.100, < 4.0)
tilt (~> 2.0)
logger (1.7.0)
loofah (2.25.2)
crass (~> 1.0.2)
nokogiri (>= 1.12.0)
mail (2.9.0)
mail (2.9.1)
logger
mini_mime (>= 0.1.1)
net-imap
Expand All @@ -177,7 +177,7 @@ GEM
minitest (6.0.6)
drb (~> 2.0)
prism (~> 1.5)
net-imap (0.6.4.1)
net-imap (0.6.6)
date
net-protocol
net-pop (0.1.2)
Expand Down Expand Up @@ -253,7 +253,7 @@ GEM
tsort (>= 0.2)
zeitwerk (~> 2.6)
rake (13.4.2)
rbs (4.0.3)
rbs (4.1.2)
logger
prism (>= 1.6.0)
tsort
Expand All @@ -264,7 +264,7 @@ GEM
tsort
reline (0.6.3)
io-console (~> 0.5)
roda (3.105.0)
roda (3.106.0)
rack
rspec (3.13.2)
rspec-core (~> 3.13.0)
Expand Down Expand Up @@ -293,22 +293,22 @@ GEM
sqlite3 (2.9.5-x86_64-linux-gnu)
sqlite3 (2.9.5-x86_64-linux-musl)
thor (1.5.0)
tilt (2.7.0)
tilt (2.8.0)
timeout (0.6.1)
tsort (0.2.0)
tzinfo (2.0.6)
concurrent-ruby (~> 1.0)
uri (1.1.1)
useragent (0.16.11)
waterdrop (2.10.2)
waterdrop (2.10.3)
karafka-core (>= 2.5.12, < 3.0.0)
karafka-rdkafka (>= 0.24.0)
zeitwerk (~> 2.3)
websocket-driver (0.8.2)
base64
websocket-extensions (>= 0.1.0)
websocket-extensions (0.1.5)
zeitwerk (2.8.2)
zeitwerk (2.8.3)

PLATFORMS
aarch64-linux-gnu
Expand All @@ -334,4 +334,4 @@ DEPENDENCIES
sqlite3 (= 2.9.5)

BUNDLED WITH
2.7.2
4.0.16
4 changes: 2 additions & 2 deletions v2.6-rails/README.md
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
# Karafka 2.5 Ruby on Rails based example application
# Karafka 2.6 Ruby on Rails based example application

This is an example application which uses:

- [Karafka framework](https://github.com/karafka/karafka) `2.5` to receive messages from [Apache Kafka](http://kafka.apache.org/) server
- [Karafka framework](https://github.com/karafka/karafka) `2.6` to receive messages from [Apache Kafka](http://kafka.apache.org/) server
- [Karafka Web UI](https://github.com/karafka/karafka-web) for Karafka processes management
- [Karafka-Testing](https://github.com/karafka/testing) provides RSpec helpers, to make testing of Karafka consumers much easier
- [Ruby on Rails ActiveJob](https://edgeguides.rubyonrails.org/active_job_basics.html) to create user instance in the background
Expand Down