issues
search
kestra-io
/
plugin-kafka
https://kestra.io/plugins/plugin-kafka/
Apache License 2.0
5
stars
5
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Commit after flush
#101
cedrelek
opened
9 hours ago
0
feat: storage now have a namespace parameter
#100
loicmathieu
closed
1 day ago
0
build(deps): bump rlespinasse/github-slug-action from 4 to 5
#99
dependabot[bot]
closed
6 days ago
1
refactor(properties): migrate to v2 properties
#98
mgabelle
closed
2 weeks ago
0
build(deps): bump andrcuns/allure-publish-action from 2.7.1 to 2.8.0
#97
dependabot[bot]
closed
3 weeks ago
1
fix: handle numeric types when generating Avro values
#96
yvrng
closed
1 month ago
3
fix: remove schema at the enum level as it clashes with the prop one
#95
loicmathieu
closed
1 month ago
0
fix: handle complex types when generating Avro values
#94
yvrng
closed
2 months ago
2
Kafka trigger timeout
#93
nikolicdragoslav
opened
2 months ago
18
fix(): changed block() to blockOptional()
#91
mgabelle
closed
2 months ago
0
fix: handle processing of an empty list or file
#90
yvrng
closed
2 months ago
0
Support Avro serdes other than Confluent
#89
paulgrainger85
opened
2 months ago
0
The Produce task fails with a NPE when an input file is empty
#88
yvrng
closed
2 months ago
0
feat(docs): add full examples for kafka tasks
#87
shrutimantri
closed
2 months ago
0
feat: plugin property v2
#86
loicmathieu
closed
2 weeks ago
0
feat: use the new FileSerde.readAll() method that improve performance
#85
loicmathieu
closed
3 months ago
0
build(deps): bump gradle/actions from 3 to 4
#84
dependabot[bot]
closed
3 months ago
0
build(deps): bump software.amazon.msk:aws-msk-iam-auth from 2.1.0 to 2.2.0
#83
dependabot[bot]
closed
3 months ago
0
build(deps): bump andrcuns/allure-publish-action from 2.6.0 to 2.7.1
#82
dependabot[bot]
closed
3 months ago
0
fix: pass the condition context to the trigger service
#81
loicmathieu
closed
4 months ago
0
build(deps): bump andrcuns/allure-publish-action from 2.6.0 to 2.7.0
#80
dependabot[bot]
closed
4 months ago
1
fix(docs): correct examples to use company.team namespace
#79
shrutimantri
closed
5 months ago
0
build(deps): bump software.amazon.msk:aws-msk-iam-auth from 2.1.0 to 2.1.1
#78
dependabot[bot]
closed
4 months ago
1
fix(docs): correct kafka realtime trigger example
#77
shrutimantri
closed
5 months ago
0
fix: remove unused property from RealtimeTrigger
#76
fhussonnois
closed
6 months ago
0
feat: enhance realtime trigger lifecycle
#75
fhussonnois
closed
6 months ago
0
refactor: migrate to Java ServiceLoader for plugin registration
#74
fhussonnois
closed
7 months ago
0
Unable to consume messages without increasing pollDuration in consumer settings
#73
brokenjacobs
closed
6 months ago
2
chore(deps): bump gradle/wrapper-validation-action from 2 to 3
#72
dependabot[bot]
closed
6 months ago
1
chore(deps): bump software.amazon.msk:aws-msk-iam-auth from 2.0.3 to 2.1.0
#71
dependabot[bot]
closed
5 months ago
0
chore(deps): bump io.github.gradle-nexus.publish-plugin from 1.3.0 to 2.0.0
#70
dependabot[bot]
closed
7 months ago
1
feat: introduce realtime trigger
#69
tchiotludo
closed
6 months ago
0
chore(deps): bump ru.vyarus.java-lib from 2.4.0 to 3.0.0
#68
dependabot[bot]
closed
6 months ago
1
chore(deps): bump ru.vyarus.github-info from 1.5.0 to 2.0.0
#67
dependabot[bot]
closed
7 months ago
1
fix: deserialize record headers as string (#65)
#66
fhussonnois
closed
9 months ago
0
Record headers should be deserialized as STRING and not as a string representation of the contents of a byte array.
#65
fhussonnois
closed
9 months ago
0
feat: add offset to consume output (#63)
#64
fhussonnois
closed
9 months ago
0
Add offset to the Consume task output
#63
fhussonnois
closed
9 months ago
0
chore: refactor to use kestra storage api
#62
fhussonnois
closed
9 months ago
0
fix: use the group.id passed through properties
#61
fhussonnois
closed
9 months ago
0
Feat/gh 59
#60
fhussonnois
closed
9 months ago
0
Allow to manually assign a consumer to a specific list of partitions
#59
fhussonnois
closed
9 months ago
0
build(deps): bump to confluent 7.5.1
#58
fhussonnois
closed
9 months ago
0
Chore/build
#57
fhussonnois
closed
9 months ago
0
feat: add support for subscribing to a topic pattern (#54)
#56
fhussonnois
closed
9 months ago
0
Kafka Consumer on a topic using a Ktable like pattern
#55
brokenjacobs
closed
8 months ago
6
Please add support to subscribing to a topic pattern using a regex
#54
brokenjacobs
closed
9 months ago
0
Can't connect with SCRAM-SHA-512 auth to my kafka broker
#53
brokenjacobs
closed
9 months ago
2
chore(deps): bump gradle/wrapper-validation-action from 1 to 2
#52
dependabot[bot]
closed
9 months ago
1
chore(deps): bump com.github.ben-manes.versions from 0.50.0 to 0.51.0
#51
dependabot[bot]
closed
9 months ago
1
Next