konnect.GatewayPluginConfluent

Example coming soon!

Example coming soon!

Example coming soon!

Example coming soon!

name string

The unique name of the resource.

args GatewayPluginConfluentArgs

The arguments to resource properties.

opts CustomResourceOptions

Bag of options to control resource's behavior.

resource_name str

The unique name of the resource.

args GatewayPluginConfluentArgs

The arguments to resource properties.

opts ResourceOptions

Bag of options to control resource's behavior.

ctx Context

Context object for the current deployment.

name string

The unique name of the resource.

args GatewayPluginConfluentArgs

The arguments to resource properties.

opts ResourceOption

Bag of options to control resource's behavior.

name string

The unique name of the resource.

args GatewayPluginConfluentArgs

The arguments to resource properties.

opts CustomResourceOptions

Bag of options to control resource's behavior.

name String

The unique name of the resource.

args GatewayPluginConfluentArgs

The arguments to resource properties.

options CustomResourceOptions

Bag of options to control resource's behavior.

ControlPlaneId string

The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.

Config GatewayPluginConfluentConfig

Consumer GatewayPluginConfluentConsumer

If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.

CreatedAt double

Unix epoch when the resource was created.

Enabled bool

Whether the plugin is applied.

GatewayPluginConfluentId string

The ID of this resource.

InstanceName string

Ordering GatewayPluginConfluentOrdering

Partials List<GatewayPluginConfluentPartial>

Protocols List<string>

A set of strings representing HTTP protocols.

Route GatewayPluginConfluentRoute

If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.

Service GatewayPluginConfluentService

If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.

Tags List<string>

An optional set of strings associated with the Plugin for grouping and filtering.

UpdatedAt double

Unix epoch when the resource was last updated.

ControlPlaneId string

The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.

Config GatewayPluginConfluentConfigArgs

Consumer GatewayPluginConfluentConsumerArgs

If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.

CreatedAt float64

Unix epoch when the resource was created.

Enabled bool

Whether the plugin is applied.

GatewayPluginConfluentId string

The ID of this resource.

InstanceName string

Ordering GatewayPluginConfluentOrderingArgs

Partials []GatewayPluginConfluentPartialArgs

Protocols []string

A set of strings representing HTTP protocols.

Route GatewayPluginConfluentRouteArgs

If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.

Service GatewayPluginConfluentServiceArgs

If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.

Tags []string

An optional set of strings associated with the Plugin for grouping and filtering.

UpdatedAt float64

Unix epoch when the resource was last updated.

controlPlaneId String

The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.

config GatewayPluginConfluentConfig

consumer GatewayPluginConfluentConsumer

If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.

createdAt Double

Unix epoch when the resource was created.

enabled Boolean

Whether the plugin is applied.

gatewayPluginConfluentId String

The ID of this resource.

instanceName String

ordering GatewayPluginConfluentOrdering

partials List<GatewayPluginConfluentPartial>

protocols List<String>

A set of strings representing HTTP protocols.

route GatewayPluginConfluentRoute

If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.

service GatewayPluginConfluentService

If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.

tags List<String>

An optional set of strings associated with the Plugin for grouping and filtering.

updatedAt Double

Unix epoch when the resource was last updated.

controlPlaneId string

The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.

config GatewayPluginConfluentConfig

consumer GatewayPluginConfluentConsumer

If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.

createdAt number

Unix epoch when the resource was created.

enabled boolean

Whether the plugin is applied.

gatewayPluginConfluentId string

The ID of this resource.

instanceName string

ordering GatewayPluginConfluentOrdering

partials GatewayPluginConfluentPartial[]

protocols string[]

A set of strings representing HTTP protocols.

route GatewayPluginConfluentRoute

If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.

service GatewayPluginConfluentService

If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.

tags string[]

An optional set of strings associated with the Plugin for grouping and filtering.

updatedAt number

Unix epoch when the resource was last updated.

control_plane_id str

The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.

config GatewayPluginConfluentConfigArgs

consumer GatewayPluginConfluentConsumerArgs

If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.

created_at float

Unix epoch when the resource was created.

enabled bool

Whether the plugin is applied.

gateway_plugin_confluent_id str

The ID of this resource.

instance_name str

ordering GatewayPluginConfluentOrderingArgs

partials Sequence[GatewayPluginConfluentPartialArgs]

protocols Sequence[str]

A set of strings representing HTTP protocols.

route GatewayPluginConfluentRouteArgs

If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.

service GatewayPluginConfluentServiceArgs

If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.

tags Sequence[str]

An optional set of strings associated with the Plugin for grouping and filtering.

updated_at float

Unix epoch when the resource was last updated.

controlPlaneId String

The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.

config Property Map

consumer Property Map

If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.

createdAt Number

Unix epoch when the resource was created.

enabled Boolean

Whether the plugin is applied.

gatewayPluginConfluentId String

The ID of this resource.

instanceName String

ordering Property Map

partials List<Property Map>

protocols List<String>

A set of strings representing HTTP protocols.

route Property Map

If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.

service Property Map

If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.

tags List<String>

An optional set of strings associated with the Plugin for grouping and filtering.

updatedAt Number

Unix epoch when the resource was last updated.

Id string

The provider-assigned unique ID for this managed resource.

Id string

The provider-assigned unique ID for this managed resource.

id String

The provider-assigned unique ID for this managed resource.

id string

The provider-assigned unique ID for this managed resource.

id str

The provider-assigned unique ID for this managed resource.

id String

The provider-assigned unique ID for this managed resource.

name

The unique name of the resulting resource.

id

The unique provider ID of the resource to lookup.

state

Any extra arguments used during the lookup.

opts

A bag of options that control this resource's behavior.

resource_name

The unique name of the resulting resource.

id

The unique provider ID of the resource to lookup.

name

The unique name of the resulting resource.

id

The unique provider ID of the resource to lookup.

state

Any extra arguments used during the lookup.

opts

A bag of options that control this resource's behavior.

name

The unique name of the resulting resource.

id

The unique provider ID of the resource to lookup.

state

Any extra arguments used during the lookup.

opts

A bag of options that control this resource's behavior.

name

The unique name of the resulting resource.

id

The unique provider ID of the resource to lookup.

state

Any extra arguments used during the lookup.

opts

A bag of options that control this resource's behavior.

AllowedTopics List<string>

The list of allowed topic names to which messages can be sent. The default topic configured in the topic field is always allowed, regardless of its inclusion in allowed_topics.

BootstrapServers List<GatewayPluginConfluentConfigBootstrapServer>

Set of bootstrap brokers in a {host: host, port: port} list format.

ClusterApiKey string

Username/Apikey for SASL authentication.

ClusterApiSecret string

Password/ApiSecret for SASL authentication.

ClusterName string

An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.

ConfluentCloudApiKey string

Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.

ConfluentCloudApiSecret string

The corresponding secret for the Confluent Cloud API key.

ForwardBody bool

Include the request body in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

ForwardHeaders bool

Include the request headers in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

ForwardMethod bool

Include the request method in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

ForwardUri bool

Include the request URI and URI arguments (as in, query arguments) in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

Keepalive double

Keepalive timeout in milliseconds.

KeepaliveEnabled bool

MessageByLuaFunctions List<string>

The Lua functions that manipulates the message being sent to the Kafka topic.

ProducerAsync bool

Flag to enable asynchronous mode.

ProducerAsyncBufferingLimitsMessagesInMemory double

Maximum number of messages that can be buffered in memory in asynchronous mode.

ProducerAsyncFlushTimeout double

Maximum time interval in milliseconds between buffer flushes in asynchronous mode.

ProducerRequestAcks double

The number of acknowledgments the producer requires the leader to have received before considering a request complete. Allowed values: 0 for no acknowledgments; 1 for only the leader; and -1 for the full ISR (In-Sync Replica set). must be one of ["-1", "0", "1"]

ProducerRequestLimitsBytesPerRequest double

Maximum size of a Produce request in bytes.

ProducerRequestLimitsMessagesPerRequest double

Maximum number of messages to include into a single producer request.

ProducerRequestRetriesBackoffTimeout double

Backoff interval between retry attempts in milliseconds.

ProducerRequestRetriesMaxAttempts double

Maximum number of retry attempts per single Produce request.

ProducerRequestTimeout double

Time to wait for a Produce response in milliseconds.

Timeout double

Socket timeout in milliseconds.

Topic string

The default Kafka topic to publish to if the query parameter defined in the topics_query_arg does not exist in the request

TopicsQueryArg string

The request query parameter name that contains the topics to publish to

AllowedTopics []string

The list of allowed topic names to which messages can be sent. The default topic configured in the topic field is always allowed, regardless of its inclusion in allowed_topics.

BootstrapServers []GatewayPluginConfluentConfigBootstrapServer

Set of bootstrap brokers in a {host: host, port: port} list format.

ClusterApiKey string

Username/Apikey for SASL authentication.

ClusterApiSecret string

Password/ApiSecret for SASL authentication.

ClusterName string

An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.

ConfluentCloudApiKey string

Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.

ConfluentCloudApiSecret string

The corresponding secret for the Confluent Cloud API key.

ForwardBody bool

Include the request body in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

ForwardHeaders bool

Include the request headers in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

ForwardMethod bool

Include the request method in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

ForwardUri bool

Include the request URI and URI arguments (as in, query arguments) in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

Keepalive float64

Keepalive timeout in milliseconds.

KeepaliveEnabled bool

MessageByLuaFunctions []string

The Lua functions that manipulates the message being sent to the Kafka topic.

ProducerAsync bool

Flag to enable asynchronous mode.

ProducerAsyncBufferingLimitsMessagesInMemory float64

Maximum number of messages that can be buffered in memory in asynchronous mode.

ProducerAsyncFlushTimeout float64

Maximum time interval in milliseconds between buffer flushes in asynchronous mode.

ProducerRequestAcks float64

The number of acknowledgments the producer requires the leader to have received before considering a request complete. Allowed values: 0 for no acknowledgments; 1 for only the leader; and -1 for the full ISR (In-Sync Replica set). must be one of ["-1", "0", "1"]

ProducerRequestLimitsBytesPerRequest float64

Maximum size of a Produce request in bytes.

ProducerRequestLimitsMessagesPerRequest float64

Maximum number of messages to include into a single producer request.

ProducerRequestRetriesBackoffTimeout float64

Backoff interval between retry attempts in milliseconds.

ProducerRequestRetriesMaxAttempts float64

Maximum number of retry attempts per single Produce request.

ProducerRequestTimeout float64

Time to wait for a Produce response in milliseconds.

Timeout float64

Socket timeout in milliseconds.

Topic string

The default Kafka topic to publish to if the query parameter defined in the topics_query_arg does not exist in the request

TopicsQueryArg string

The request query parameter name that contains the topics to publish to

allowedTopics List<String>

The list of allowed topic names to which messages can be sent. The default topic configured in the topic field is always allowed, regardless of its inclusion in allowed_topics.

bootstrapServers List<GatewayPluginConfluentConfigBootstrapServer>

Set of bootstrap brokers in a {host: host, port: port} list format.

clusterApiKey String

Username/Apikey for SASL authentication.

clusterApiSecret String

Password/ApiSecret for SASL authentication.

clusterName String

An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.

confluentCloudApiKey String

Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.

confluentCloudApiSecret String

The corresponding secret for the Confluent Cloud API key.

forwardBody Boolean

Include the request body in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forwardHeaders Boolean

Include the request headers in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forwardMethod Boolean

Include the request method in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forwardUri Boolean

Include the request URI and URI arguments (as in, query arguments) in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

keepalive Double

Keepalive timeout in milliseconds.

keepaliveEnabled Boolean

messageByLuaFunctions List<String>

The Lua functions that manipulates the message being sent to the Kafka topic.

producerAsync Boolean

Flag to enable asynchronous mode.

producerAsyncBufferingLimitsMessagesInMemory Double

Maximum number of messages that can be buffered in memory in asynchronous mode.

producerAsyncFlushTimeout Double

Maximum time interval in milliseconds between buffer flushes in asynchronous mode.

producerRequestAcks Double

The number of acknowledgments the producer requires the leader to have received before considering a request complete. Allowed values: 0 for no acknowledgments; 1 for only the leader; and -1 for the full ISR (In-Sync Replica set). must be one of ["-1", "0", "1"]

producerRequestLimitsBytesPerRequest Double

Maximum size of a Produce request in bytes.

producerRequestLimitsMessagesPerRequest Double

Maximum number of messages to include into a single producer request.

producerRequestRetriesBackoffTimeout Double

Backoff interval between retry attempts in milliseconds.

producerRequestRetriesMaxAttempts Double

Maximum number of retry attempts per single Produce request.

producerRequestTimeout Double

Time to wait for a Produce response in milliseconds.

timeout Double

Socket timeout in milliseconds.

topic String

The default Kafka topic to publish to if the query parameter defined in the topics_query_arg does not exist in the request

topicsQueryArg String

The request query parameter name that contains the topics to publish to

allowedTopics string[]

The list of allowed topic names to which messages can be sent. The default topic configured in the topic field is always allowed, regardless of its inclusion in allowed_topics.

bootstrapServers GatewayPluginConfluentConfigBootstrapServer[]

Set of bootstrap brokers in a {host: host, port: port} list format.

clusterApiKey string

Username/Apikey for SASL authentication.

clusterApiSecret string

Password/ApiSecret for SASL authentication.

clusterName string

An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.

confluentCloudApiKey string

Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.

confluentCloudApiSecret string

The corresponding secret for the Confluent Cloud API key.

forwardBody boolean

Include the request body in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forwardHeaders boolean

Include the request headers in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forwardMethod boolean

Include the request method in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forwardUri boolean

Include the request URI and URI arguments (as in, query arguments) in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

keepalive number

Keepalive timeout in milliseconds.

keepaliveEnabled boolean

messageByLuaFunctions string[]

The Lua functions that manipulates the message being sent to the Kafka topic.

producerAsync boolean

Flag to enable asynchronous mode.

producerAsyncBufferingLimitsMessagesInMemory number

Maximum number of messages that can be buffered in memory in asynchronous mode.

producerAsyncFlushTimeout number

Maximum time interval in milliseconds between buffer flushes in asynchronous mode.

producerRequestAcks number

The number of acknowledgments the producer requires the leader to have received before considering a request complete. Allowed values: 0 for no acknowledgments; 1 for only the leader; and -1 for the full ISR (In-Sync Replica set). must be one of ["-1", "0", "1"]

producerRequestLimitsBytesPerRequest number

Maximum size of a Produce request in bytes.

producerRequestLimitsMessagesPerRequest number

Maximum number of messages to include into a single producer request.

producerRequestRetriesBackoffTimeout number

Backoff interval between retry attempts in milliseconds.

producerRequestRetriesMaxAttempts number

Maximum number of retry attempts per single Produce request.

producerRequestTimeout number

Time to wait for a Produce response in milliseconds.

timeout number

Socket timeout in milliseconds.

topic string

The default Kafka topic to publish to if the query parameter defined in the topics_query_arg does not exist in the request

topicsQueryArg string

The request query parameter name that contains the topics to publish to

allowed_topics Sequence[str]

The list of allowed topic names to which messages can be sent. The default topic configured in the topic field is always allowed, regardless of its inclusion in allowed_topics.

bootstrap_servers Sequence[GatewayPluginConfluentConfigBootstrapServer]

Set of bootstrap brokers in a {host: host, port: port} list format.

cluster_api_key str

Username/Apikey for SASL authentication.

cluster_api_secret str

Password/ApiSecret for SASL authentication.

cluster_name str

An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.

confluent_cloud_api_key str

Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.

confluent_cloud_api_secret str

The corresponding secret for the Confluent Cloud API key.

forward_body bool

Include the request body in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forward_headers bool

Include the request headers in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forward_method bool

Include the request method in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forward_uri bool

Include the request URI and URI arguments (as in, query arguments) in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

keepalive float

Keepalive timeout in milliseconds.

keepalive_enabled bool

message_by_lua_functions Sequence[str]

The Lua functions that manipulates the message being sent to the Kafka topic.

producer_async bool

Flag to enable asynchronous mode.

producer_async_buffering_limits_messages_in_memory float

Maximum number of messages that can be buffered in memory in asynchronous mode.

producer_async_flush_timeout float

Maximum time interval in milliseconds between buffer flushes in asynchronous mode.

producer_request_acks float

The number of acknowledgments the producer requires the leader to have received before considering a request complete. Allowed values: 0 for no acknowledgments; 1 for only the leader; and -1 for the full ISR (In-Sync Replica set). must be one of ["-1", "0", "1"]

producer_request_limits_bytes_per_request float

Maximum size of a Produce request in bytes.

producer_request_limits_messages_per_request float

Maximum number of messages to include into a single producer request.

producer_request_retries_backoff_timeout float

Backoff interval between retry attempts in milliseconds.

producer_request_retries_max_attempts float

Maximum number of retry attempts per single Produce request.

producer_request_timeout float

Time to wait for a Produce response in milliseconds.

timeout float

Socket timeout in milliseconds.

topic str

The default Kafka topic to publish to if the query parameter defined in the topics_query_arg does not exist in the request

topics_query_arg str

The request query parameter name that contains the topics to publish to

allowedTopics List<String>

The list of allowed topic names to which messages can be sent. The default topic configured in the topic field is always allowed, regardless of its inclusion in allowed_topics.

bootstrapServers List<Property Map>

Set of bootstrap brokers in a {host: host, port: port} list format.

clusterApiKey String

Username/Apikey for SASL authentication.

clusterApiSecret String

Password/ApiSecret for SASL authentication.

clusterName String

An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.

confluentCloudApiKey String

Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.

confluentCloudApiSecret String

The corresponding secret for the Confluent Cloud API key.

forwardBody Boolean

Include the request body in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forwardHeaders Boolean

Include the request headers in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forwardMethod Boolean

Include the request method in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

forwardUri Boolean

Include the request URI and URI arguments (as in, query arguments) in the message. At least one of these must be true: forward_method, forward_uri, forward_headers, forward_body.

keepalive Number

Keepalive timeout in milliseconds.

keepaliveEnabled Boolean

messageByLuaFunctions List<String>

The Lua functions that manipulates the message being sent to the Kafka topic.

producerAsync Boolean

Flag to enable asynchronous mode.

producerAsyncBufferingLimitsMessagesInMemory Number

Maximum number of messages that can be buffered in memory in asynchronous mode.

producerAsyncFlushTimeout Number

Maximum time interval in milliseconds between buffer flushes in asynchronous mode.

producerRequestAcks Number

The number of acknowledgments the producer requires the leader to have received before considering a request complete. Allowed values: 0 for no acknowledgments; 1 for only the leader; and -1 for the full ISR (In-Sync Replica set). must be one of ["-1", "0", "1"]

producerRequestLimitsBytesPerRequest Number

Maximum size of a Produce request in bytes.

producerRequestLimitsMessagesPerRequest Number

Maximum number of messages to include into a single producer request.

producerRequestRetriesBackoffTimeout Number

Backoff interval between retry attempts in milliseconds.

producerRequestRetriesMaxAttempts Number

Maximum number of retry attempts per single Produce request.

producerRequestTimeout Number

Time to wait for a Produce response in milliseconds.

timeout Number

Socket timeout in milliseconds.

topic String

The default Kafka topic to publish to if the query parameter defined in the topics_query_arg does not exist in the request

topicsQueryArg String

The request query parameter name that contains the topics to publish to

Host string

A string representing a host name, such as example.com. Not Null

Port double

An integer representing a port number between 0 and 65535, inclusive. Not Null

Host string

A string representing a host name, such as example.com. Not Null

Port float64

An integer representing a port number between 0 and 65535, inclusive. Not Null

host String

A string representing a host name, such as example.com. Not Null

port Double

An integer representing a port number between 0 and 65535, inclusive. Not Null

host string

A string representing a host name, such as example.com. Not Null

port number

An integer representing a port number between 0 and 65535, inclusive. Not Null

host str

A string representing a host name, such as example.com. Not Null

port float

An integer representing a port number between 0 and 65535, inclusive. Not Null

host String

A string representing a host name, such as example.com. Not Null

port Number

An integer representing a port number between 0 and 65535, inclusive. Not Null

Id string

Id string

id String

id string