Ecosyste.ms: Repos
An open API service providing repository metadata for many open source software ecosystems.
GitHub / quarkiverse / quarkus-kafka-streams-processor
Easily build resilient Kafka Streams topologies based on the Processor API
Stars: 6
Forks: 3
Open Issues: 8
License: apache-2.0
Language: Java
Repo Size: 339 KB
Dependencies:
268
Created: 5 months ago
Updated: about 1 month ago
Last pushed: 2 months ago
Last synced: 2 months ago
Topics: kafka-streams, quarkus-extension, resiliency
Files
Loading...
Readme
Loading...
Dependencies
.github/workflows/build.yml
actions
- actions/checkout v3 composite
- actions/setup-java v3 composite
- radcortez/project-metadata-action master composite
- actions/checkout v3 composite
- actions/setup-java v3 composite
- dcarbone/install-yq-action v1.0.1 composite
.github/workflows/release.yml
actions
- actions/checkout v3 composite
- actions/setup-java v3 composite
- crazy-max/ghaction-import-gpg v5 composite
- radcortez/project-metadata-action main composite
api/pom.xml
maven
- org.projectlombok:lombok provided
- com.fasterxml.jackson.core:jackson-core
- com.fasterxml.jackson.core:jackson-databind
- io.quarkus:quarkus-core
- io.smallrye.config:smallrye-config-core
- jakarta.enterprise:jakarta.enterprise.cdi-api
- jakarta.inject:jakarta.inject-api
- org.apache.kafka:kafka-clients
- org.apache.kafka:kafka-streams
- org.eclipse.microprofile.config:microprofile-config-api
- org.eclipse.microprofile.fault-tolerance:microprofile-fault-tolerance-api
- org.slf4j:slf4j-api
- org.junit.jupiter:junit-jupiter-api test
- org.junit.jupiter:junit-jupiter-engine test
- org.mockito:mockito-core test
- org.mockito:mockito-junit-jupiter test
bom/application/pom.xml
maven
bom/pom.xml
maven
bom/test/pom.xml
maven
deployment/pom.xml
maven
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor ${project.version}
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-api
- io.quarkus:quarkus-arc-deployment
- io.quarkus:quarkus-jackson-deployment
- io.quarkus:quarkus-kafka-streams-deployment
- io.quarkus:quarkus-micrometer-deployment
- io.quarkus:quarkus-mutiny-deployment
- io.quarkus:quarkus-opentelemetry-deployment
- io.quarkus:quarkus-smallrye-context-propagation-deployment
- io.quarkus:quarkus-smallrye-fault-tolerance-deployment
- io.quarkus:quarkus-junit5-internal test
docs/pom.xml
maven
impl/pom.xml
maven
- org.projectlombok:lombok provided
- com.fasterxml.jackson.core:jackson-annotations
- com.fasterxml.jackson.core:jackson-core
- com.fasterxml.jackson.core:jackson-databind
- com.github.daniel-shuy:kafka-protobuf-serde
- com.google.protobuf:protobuf-java
- com.google.protobuf:protobuf-java-util
- io.micrometer:micrometer-core
- io.opentelemetry:opentelemetry-api
- io.opentelemetry:opentelemetry-context
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-api
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-text-map-accessors
- io.quarkus.arc:arc
- io.quarkus.arc:arc-processor
- io.quarkus:quarkus-core
- io.quarkus:quarkus-smallrye-fault-tolerance
- jakarta.annotation:jakarta.annotation-api
- jakarta.enterprise:jakarta.enterprise.cdi-api
- jakarta.inject:jakarta.inject-api
- org.apache.kafka:kafka-clients
- org.apache.kafka:kafka-streams
- org.eclipse.microprofile.config:microprofile-config-api
- org.eclipse.microprofile.fault-tolerance:microprofile-fault-tolerance-api
- org.eclipse.microprofile.health:microprofile-health-api
- org.slf4j:slf4j-api
- com.github.os72:protobuf-dynamic test
- com.vaadin.external.google:android-json 0.0.20131108.vaadin1 test
- commons-io:commons-io test
- de.sven-jacobs:loremipsum test
- io.opentelemetry:opentelemetry-sdk-testing test
- io.quarkus:quarkus-junit5 test
- io.quarkus:quarkus-junit5-internal test
- io.quarkus:quarkus-junit5-mockito test
- io.quarkus:quarkus-kafka-streams test
- io.quarkus:quarkus-micrometer-registry-prometheus test
- io.quarkus:quarkus-opentelemetry test
- io.quarkus:quarkus-smallrye-health test
- io.quarkus:quarkus-test-common test
- io.rest-assured:json-path test
- io.rest-assured:rest-assured test
- org.apache.kafka:kafka-clients test
- org.apache.kafka:kafka-metadata test
- org.apache.kafka:kafka-streams-test-utils test
- org.assertj:assertj-core test
- org.hamcrest:hamcrest test
- org.junit.jupiter:junit-jupiter-api test
- org.junit.jupiter:junit-jupiter-engine test
- org.mockito:mockito-core test
- org.mockito:mockito-junit-jupiter test
- org.skyscreamer:jsonassert test
- org.springframework.kafka:spring-kafka-test test
- org.projectlombok:lombok provided
- com.fasterxml.jackson.core:jackson-annotations
- com.fasterxml.jackson.core:jackson-core
- com.fasterxml.jackson.core:jackson-databind
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-api
- io.quarkus:quarkus-jackson
- io.quarkus:quarkus-kafka-streams
- io.quarkus:quarkus-micrometer-registry-prometheus
- io.quarkus:quarkus-opentelemetry
- io.quarkus:quarkus-smallrye-health
- jakarta.enterprise:jakarta.enterprise.cdi-api
- jakarta.inject:jakarta.inject-api
- org.apache.kafka:kafka-clients
- org.apache.kafka:kafka-streams
- org.eclipse.microprofile.config:microprofile-config-api
- org.slf4j:slf4j-api
- com.github.daniel-shuy:kafka-protobuf-serde test
- io.quarkus:quarkus-junit5 test
- io.quarkus:quarkus-test-common test
- io.rest-assured:rest-assured test
- org.apache.kafka:kafka-streams-test-utils test
- org.awaitility:awaitility test
- org.hamcrest:hamcrest test
- org.junit.jupiter:junit-jupiter-api test
- org.junit.jupiter:junit-jupiter-engine test
- org.mockito:mockito-core test
- org.mockito:mockito-junit-jupiter test
- org.springframework.kafka:spring-kafka-test test
- org.projectlombok:lombok provided
- io.micrometer:micrometer-core
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-api
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-protobuf-binding ${project.version}
- io.quarkus:quarkus-kafka-streams
- io.quarkus:quarkus-micrometer-registry-prometheus
- io.quarkus:quarkus-opentelemetry
- io.quarkus:quarkus-rest-client-reactive
- io.quarkus:quarkus-resteasy-reactive-jsonb
- io.quarkus:quarkus-smallrye-health
- jakarta.enterprise:jakarta.enterprise.cdi-api
- jakarta.inject:jakarta.inject-api
- jakarta.ws.rs:jakarta.ws.rs-api
- org.apache.kafka:kafka-streams
- org.eclipse.microprofile.config:microprofile-config-api
- org.eclipse.microprofile.rest.client:microprofile-rest-client-api
- org.slf4j:slf4j-api
- com.github.daniel-shuy:kafka-protobuf-serde test
- com.spotify:hamcrest-future test
- io.quarkus:quarkus-junit5 test
- io.quarkus:quarkus-junit5-mockito test
- io.quarkus:quarkus-test-common test
- net.jodah:concurrentunit test
- org.apache.kafka:kafka-clients test
- org.awaitility:awaitility test
- org.hamcrest:hamcrest test
- org.junit.jupiter:junit-jupiter-api test
- org.junit.jupiter:junit-jupiter-engine test
- org.mock-server:mockserver-client-java test
- org.mock-server:mockserver-core test
- org.mock-server:mockserver-netty test
- org.mockito:mockito-core test
- org.mockito:mockito-junit-jupiter test
- org.springframework.kafka:spring-kafka-test test
- org.projectlombok:lombok provided
- com.google.protobuf:protobuf-java
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-api
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-protobuf-binding ${project.version}
- io.quarkus:quarkus-kafka-streams
- io.quarkus:quarkus-micrometer-registry-prometheus
- io.quarkus:quarkus-opentelemetry
- io.quarkus:quarkus-smallrye-health
- jakarta.enterprise:jakarta.enterprise.cdi-api
- jakarta.inject:jakarta.inject-api
- org.apache.kafka:kafka-clients
- org.apache.kafka:kafka-streams
- org.eclipse.microprofile.config:microprofile-config-api
- org.slf4j:slf4j-api
- com.github.daniel-shuy:kafka-protobuf-serde test
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-test-framework test
- io.quarkus:quarkus-junit5 test
- io.quarkus:quarkus-kafka-client test
- io.quarkus:quarkus-test-common test
- org.apache.kafka:kafka-streams-test-utils test
- org.awaitility:awaitility test
- org.hamcrest:hamcrest test
- org.junit.jupiter:junit-jupiter-api test
- org.junit.jupiter:junit-jupiter-engine test
- org.mockito:mockito-core test
- org.mockito:mockito-junit-jupiter test
- org.springframework.kafka:spring-kafka-test test
- org.projectlombok:lombok provided
- de.sven-jacobs:loremipsum
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-api
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-protobuf-binding ${project.version}
- io.quarkus:quarkus-kafka-streams
- io.quarkus:quarkus-micrometer-registry-prometheus
- io.quarkus:quarkus-opentelemetry
- io.quarkus:quarkus-smallrye-health
- jakarta.enterprise:jakarta.enterprise.cdi-api
- jakarta.inject:jakarta.inject-api
- org.apache.kafka:kafka-clients
- org.apache.kafka:kafka-streams
- org.eclipse.microprofile.config:microprofile-config-api
- org.slf4j:slf4j-api
- com.github.daniel-shuy:kafka-protobuf-serde test
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-test-framework test
- io.quarkus:quarkus-junit5 test
- io.quarkus:quarkus-test-common test
- io.rest-assured:rest-assured test
- org.apache.kafka:kafka-streams-test-utils test
- org.awaitility:awaitility test
- org.hamcrest:hamcrest test
- org.junit.jupiter:junit-jupiter-api test
- org.junit.jupiter:junit-jupiter-engine test
- org.mockito:mockito-core test
- org.mockito:mockito-junit-jupiter test
- org.springframework.kafka:spring-kafka-test test
- org.projectlombok:lombok provided
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-api
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-protobuf-binding ${project.version}
- io.quarkus:quarkus-kafka-streams
- io.quarkus:quarkus-micrometer-registry-prometheus
- io.quarkus:quarkus-opentelemetry
- io.quarkus:quarkus-smallrye-health
- jakarta.enterprise:jakarta.enterprise.cdi-api
- jakarta.inject:jakarta.inject-api
- org.apache.commons:commons-lang3
- org.apache.kafka:kafka-clients
- org.apache.kafka:kafka-streams
- org.eclipse.microprofile.config:microprofile-config-api
- org.slf4j:slf4j-api
- com.github.daniel-shuy:kafka-protobuf-serde test
- io.quarkiverse.kafkastreamsprocessor:quarkus-kafka-streams-processor-test-framework test
- io.quarkus:quarkus-junit5 test
- io.quarkus:quarkus-test-common test
- io.rest-assured:rest-assured test
- org.apache.kafka:kafka-streams-test-utils test
- org.awaitility:awaitility test
- org.hamcrest:hamcrest test
- org.jboss.logmanager:jboss-logmanager-embedded test
- org.junit.jupiter:junit-jupiter-api test
- org.junit.jupiter:junit-jupiter-engine test
- org.mockito:mockito-core test
- org.mockito:mockito-junit-jupiter test
- org.springframework.kafka:spring-kafka-test test
pom.xml
maven
runtime/pom.xml
maven
test-framework/pom.xml
maven
- org.projectlombok:lombok provided
- io.quarkus:quarkus-test-common
- org.eclipse.microprofile.config:microprofile-config-api
- org.slf4j:slf4j-api
- org.hamcrest:hamcrest test
- org.jboss.logmanager:jboss-logmanager-embedded test
- org.junit.jupiter:junit-jupiter-api test
- org.junit.jupiter:junit-jupiter-engine test
- org.mockito:mockito-core test
- org.mockito:mockito-junit-jupiter test
- com.google.code.findbugs:jsr305
- io.opentelemetry:opentelemetry-context
- jakarta.enterprise:jakarta.enterprise.cdi-api
- org.apache.kafka:kafka-clients
- org.hamcrest:hamcrest test
- org.jboss.logmanager:jboss-logmanager-embedded test
- org.junit.jupiter:junit-jupiter-api test
- org.junit.jupiter:junit-jupiter-engine test