-
Notifications
You must be signed in to change notification settings - Fork 785
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Additional kafka_franz
input kafka consumer configuration
#2573
base: main
Are you sure you want to change the base?
Additional kafka_franz
input kafka consumer configuration
#2573
Commits on May 10, 2024
-
Adds additional kafka fields to output
- `fetch_min_bytes` - `fetch_max_wait_ms` - `max_partition_fetch_bytes` - `max_poll_records` I've used the defaults, as what kafka defaults are Signed-off-by: hendoxc <hagen.henderson@smartcontract.com>
Configuration menu - View commit details
-
Copy full SHA for fbb0313 - Browse repository at this point
Copy the full SHA fbb0313View commit details -
Changes
fetch_max_wait
to a Duration Fieldmatches what franz go library expects when configuring a client Signed-off-by: hendoxc <hagen.henderson@smartcontract.com>
Configuration menu - View commit details
-
Copy full SHA for fb27b8b - Browse repository at this point
Copy the full SHA fb27b8bView commit details -
Adds additional config fields to
franzKafkaReader
Signed-off-by: hendoxc <hagen.henderson@smartcontract.com>
Configuration menu - View commit details
-
Copy full SHA for 4d7a170 - Browse repository at this point
Copy the full SHA 4d7a170View commit details -
Adds new fields to client instantiation
additionally removes `max_poll_records` as its not an available client option Signed-off-by: hendoxc <hagen.henderson@smartcontract.com>
Configuration menu - View commit details
-
Copy full SHA for 7ee5dff - Browse repository at this point
Copy the full SHA 7ee5dffView commit details -
Signed-off-by: hendoxc <hagen.henderson@smartcontract.com>
Configuration menu - View commit details
-
Copy full SHA for ad12716 - Browse repository at this point
Copy the full SHA ad12716View commit details -
Makes default for
fetch_max_wait_duration
to5s
this is the franz client's default Signed-off-by: hendoxc <hagen.henderson@smartcontract.com>
Configuration menu - View commit details
-
Copy full SHA for 0a86319 - Browse repository at this point
Copy the full SHA 0a86319View commit details
Commits on May 16, 2024
-
Configuration menu - View commit details
-
Copy full SHA for 77577b1 - Browse repository at this point
Copy the full SHA 77577b1View commit details