Skip to content
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.

Sign up for GitHub

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

feat: support rdkafka2 options #1875

Merged
merged 4 commits into from
Dec 16, 2024
+2,942 −2
Merged

feat: support rdkafka2 options #1875

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
c6a154d
feat: support rdkafka2 options
withlin Dec 2, 2024
77aa696
fix: some nits
withlin Dec 4, 2024
766970f
fix: missing markdown
withlin Dec 4, 2024
ca91c14
chore: fix rdkafka options tests
pepov Dec 16, 2024
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
374 changes: 374 additions & 0 deletions ...perator/charts/logging-operator-crds/templates/logging.banzaicloud.io_clusteroutputs.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3267,6 +3267,193 @@ spec:
type: object
principal:
type: string
rdkafka_options:
properties:
allow.auto.create.topics:
type: boolean
api.version.fallback.ms:
type: integer
api.version.request:
type: boolean
api.version.request.timeout.ms:
type: integer
background_event_cb:
type: string
bootstrap.servers:
type: string
broker.address.family:
type: string
broker.address.ttl:
type: integer
broker.version.fallback:
type: string
builtin.features:
type: string
client.id:
type: string
closesocket_cb:
type: string
connect_cb:
type: string
connections.max.idle.ms:
type: integer
debug:
type: string
default_topic_conf:
type: string
enable.random.seed:
type: boolean
enable.sasl.oauthbearer.unsecure.jwt:
type: boolean
enable.ssl.certificate.verification:
type: boolean
enabled_events:
type: integer
error_cb:
type: string
interceptors:
type: string
internal.termination.signal:
type: integer
log.connection.close:
type: boolean
log.queue:
type: boolean
log.thread.name:
type: boolean
log_cb:
type: string
log_level:
type: integer
max.in.flight:
type: integer
max.in.flight.requests.per.connection:
type: integer
message.copy.max.bytes:
type: integer
message.max.bytes:
type: integer
metadata.broker.list:
type: string
metadata.max.age.ms:
type: integer
oauthbearer_token_refresh_cb:
type: string
opaque:
type: string
open_cb:
type: string
plugin.library.paths:
type: string
receive.message.max.bytes:
type: integer
reconnect.backoff.max.ms:
type: integer
reconnect.backoff.ms:
type: integer
resolve_cb:
type: string
sasl.kerberos.keytab:
type: string
sasl.kerberos.kinit.cmd:
type: string
sasl.kerberos.min.time.before.relogin:
type: integer
sasl.kerberos.principal:
type: string
sasl.kerberos.service.name:
type: string
sasl.mechanisms:
type: string
sasl.oauthbearer.client.id:
type: string
sasl.oauthbearer.client.secret:
type: string
sasl.oauthbearer.config:
type: string
sasl.oauthbearer.extensions:
type: string
sasl.oauthbearer.method:
type: string
sasl.oauthbearer.scope:
type: string
sasl.oauthbearer.token.endpoint.url:
type: string
sasl.password:
type: string
sasl.username:
type: string
security.protocol:
type: string
socket.blocking.max.ms:
type: integer
socket.connection.setup.timeout.ms:
type: integer
socket.keepalive.enable:
type: boolean
socket.max.fails:
type: integer
socket.nagle.disable:
type: boolean
socket.receive.buffer.bytes:
type: integer
socket.send.buffer.bytes:
type: integer
socket.timeout.ms:
type: integer
socket_cb:
type: string
ssl.ca.location:
type: string
ssl.ca.pem:
type: string
ssl.certificate.location:
type: string
ssl.certificate.pem:
type: string
ssl.cipher.suites:
type: string
ssl.crl.location:
type: string
ssl.curves.list:
type: string
ssl.endpoint.identification.algorithm:
type: string
ssl.engine.id:
type: string
ssl.engine.location:
type: string
ssl.key.location:
type: string
ssl.key.password:
type: string
ssl.key.pem:
type: string
ssl.keystore.location:
type: string
ssl.keystore.password:
type: string
ssl.providers:
type: string
ssl.sigalgs.list:
type: string
statistics.interval.ms:
type: integer
stats_cb:
type: string
throttle_cb:
type: string
topic.blacklist:
type: string
topic.metadata.propagation.max.ms:
type: integer
topic.metadata.refresh.fast.interval.ms:
type: integer
topic.metadata.refresh.interval.ms:
type: integer
topic.metadata.refresh.sparse:
type: boolean
type: object
required_acks:
type: integer
sasl_over_ssl:
Expand Down Expand Up @@ -10519,6 +10706,193 @@ spec:
type: object
principal:
type: string
rdkafka_options:
properties:
allow.auto.create.topics:
type: boolean
api.version.fallback.ms:
type: integer
api.version.request:
type: boolean
api.version.request.timeout.ms:
type: integer
background_event_cb:
type: string
bootstrap.servers:
type: string
broker.address.family:
type: string
broker.address.ttl:
type: integer
broker.version.fallback:
type: string
builtin.features:
type: string
client.id:
type: string
closesocket_cb:
type: string
connect_cb:
type: string
connections.max.idle.ms:
type: integer
debug:
type: string
default_topic_conf:
type: string
enable.random.seed:
type: boolean
enable.sasl.oauthbearer.unsecure.jwt:
type: boolean
enable.ssl.certificate.verification:
type: boolean
enabled_events:
type: integer
error_cb:
type: string
interceptors:
type: string
internal.termination.signal:
type: integer
log.connection.close:
type: boolean
log.queue:
type: boolean
log.thread.name:
type: boolean
log_cb:
type: string
log_level:
type: integer
max.in.flight:
type: integer
max.in.flight.requests.per.connection:
type: integer
message.copy.max.bytes:
type: integer
message.max.bytes:
type: integer
metadata.broker.list:
type: string
metadata.max.age.ms:
type: integer
oauthbearer_token_refresh_cb:
type: string
opaque:
type: string
open_cb:
type: string
plugin.library.paths:
type: string
receive.message.max.bytes:
type: integer
reconnect.backoff.max.ms:
type: integer
reconnect.backoff.ms:
type: integer
resolve_cb:
type: string
sasl.kerberos.keytab:
type: string
sasl.kerberos.kinit.cmd:
type: string
sasl.kerberos.min.time.before.relogin:
type: integer
sasl.kerberos.principal:
type: string
sasl.kerberos.service.name:
type: string
sasl.mechanisms:
type: string
sasl.oauthbearer.client.id:
type: string
sasl.oauthbearer.client.secret:
type: string
sasl.oauthbearer.config:
type: string
sasl.oauthbearer.extensions:
type: string
sasl.oauthbearer.method:
type: string
sasl.oauthbearer.scope:
type: string
sasl.oauthbearer.token.endpoint.url:
type: string
sasl.password:
type: string
sasl.username:
type: string
security.protocol:
type: string
socket.blocking.max.ms:
type: integer
socket.connection.setup.timeout.ms:
type: integer
socket.keepalive.enable:
type: boolean
socket.max.fails:
type: integer
socket.nagle.disable:
type: boolean
socket.receive.buffer.bytes:
type: integer
socket.send.buffer.bytes:
type: integer
socket.timeout.ms:
type: integer
socket_cb:
type: string
ssl.ca.location:
type: string
ssl.ca.pem:
type: string
ssl.certificate.location:
type: string
ssl.certificate.pem:
type: string
ssl.cipher.suites:
type: string
ssl.crl.location:
type: string
ssl.curves.list:
type: string
ssl.endpoint.identification.algorithm:
type: string
ssl.engine.id:
type: string
ssl.engine.location:
type: string
ssl.key.location:
type: string
ssl.key.password:
type: string
ssl.key.pem:
type: string
ssl.keystore.location:
type: string
ssl.keystore.password:
type: string
ssl.providers:
type: string
ssl.sigalgs.list:
type: string
statistics.interval.ms:
type: integer
stats_cb:
type: string
throttle_cb:
type: string
topic.blacklist:
type: string
topic.metadata.propagation.max.ms:
type: integer
topic.metadata.refresh.fast.interval.ms:
type: integer
topic.metadata.refresh.interval.ms:
type: integer
topic.metadata.refresh.sparse:
type: boolean
type: object
required_acks:
type: integer
sasl_over_ssl:
Expand Down
Loading
Loading