Tagged posts: '#kafka'

How Trax uses Quarkus to stream Oracle change data through Debezium and Kafka Streams and push it live to React and Swift iOS clients over WebSockets. Trax is an aviation MRO software provider whose systems cover thousands of aircraft for airlines, cargo operators and maintenance providers worldwide.

Explore how to verify Quarkus event-driven applications with the Citrus integration test framework.

Learn about the virtual threads integration in Quarkus messaging (Kafka, AMQP, Pulsar...).

JSON, Avro and Custom Kafka Serializers and Deserializers with Quarkus

Banco do Brasil extracts investment data from the Brazilian Open Banking environment using Quarkus and Kafka to scale horizontally the processing with multiple instances and simultaneous worker threads.

Introduction to the Quarkus Superheroes sample application, discusses some of the requirements for building it, and illustrates how to run it locally or deploy it to Kubernetes.

How to build a Quarkus application using Apache Kafka in less than 10 minutes

How to use Kafka and Avro in a native executable

How to send and receive Cloud Events with Quarkus, Kafka and Reactive Messaging

Kafka - When to commit?

Offset commiting strategies in the Kafka connector

Failure handling in the Kafka connector

How to Use Kafka, Schema Registry, and Avro with Quarkus

How to combine reactive messaging, Kafka and the Rest client

Kafka Streams is a very popular solution for implementing stream processing applications based on Apache Kafka. It lets you do typical data streaming tasks like filtering and transforming messages, joining multiple Kafka topics, performing (stateful) calculations, grouping and aggregating values in time windows and much more. Unlike other streaming query engines that run on specific processing clusters, Kafka Streams is a client library. This means a (Java) application is needed which starts and runs the...

Tags

a2a
agentic
agents
ai
amqp
angular
announcement
aot
api
apicurio
arc
arm
async
atlasmap
avro
awards
benchmarking
build-time
cache
camel
cassandra
cdi
chatgpt
chicory
claude
cloud
cloud-native
cloudwatch
codestarts
coding-agents
conference
config
containers
contribution
crud
cryostat
data
data-mapping
database
debezium
debugger
developer-experience
development
development-tips
documentation
dpop
elasticsearch
event
event-driven
extension
fault-tolerance
feature
framework
frontend
gc
gemini
gitlab
gizmo
gpt
graalvm
graphql
grpc
guardrails
gui
hacktoberfest
hibernate
howto
http
iceberg
ide
images
infinispan
integration
intellij
introduction
jackson
jakarta
jandex
java
javascript
jdiameter
jetbrains
jfr
jlama
jpa
json
jvm
kafka
keycloak
kubernetes
langchain4j
leyden
library
llm
local-inference
logging
loom
lts
mandrel
maven
mcp
messaging
metrics
micrometer
microprofile
migrate-spring-to-quarkus
migration
monitoring
mta
mtls
mutiny
native
neo4j
newsletter
nodejs
oauth2
observability
oidc
opa
openapi
openshift
opentelemetry
pagination
panache
patternfly
performance
persistence
pgo
podcast
podman
polaris
profiling
prometheus
quarkiverse
quarkus-insights
quarkus-mcp-server
qute
rag
raspberrypi
react
reactive
redis
release
rest
resteasy
retry
rss
runtime
search
security
semeru
sentry
serialization
skill
smallrye
smallrye-stork
spring
sqlite
stork
streams
swagger-ui
testcontainers
testing
tracing
ubi
unleash
user-story
vert-x
virtual-threads
wasm
web
webassembly
website
websockets
windows
workflow