Class: Aws::Pipes::Types::UpdatePipeSourceSelfManagedKafkaParameters

Inherits:
Struct
  • Object
show all
Includes:
Structure
Defined in:
lib/aws-sdk-pipes/types.rb

Overview

The parameters for using a self-managed Apache Kafka stream as a source.

A *self managed* cluster refers to any Apache Kafka cluster not hosted by Amazon Web Services. This includes both clusters you manage yourself, as well as those hosted by a third-party provider, such as [Confluent Cloud], [CloudKarafka], or [Redpanda]. For more information, see [Apache Kafka streams as a source] in the *Amazon EventBridge User Guide*.

[1]: www.confluent.io/ [2]: www.cloudkarafka.com/ [3]: redpanda.com/ [4]: docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-kafka.html

See Also:

Constant Summary collapse

SENSITIVE = 
[]

Instance Attribute Summary collapse

Instance Attribute Details

#batch_size ⇒ Integer

The maximum number of records to include in each batch.

Returns:

  • (Integer) 


3667
3668
3669
3670
3671
3672
3673
3674
3675
 
# File 'lib/aws-sdk-pipes/types.rb', line 3667

class UpdatePipeSourceSelfManagedKafkaParameters < Struct.new(
  :batch_size,
  :maximum_batching_window_in_seconds,
  :credentials,
  :server_root_ca_certificate,
  :vpc)
  SENSITIVE = []
  include Aws::Structure
end

#credentials ⇒ Types::SelfManagedKafkaAccessConfigurationCredentials

The credentials needed to access the resource.

Returns:



3667
3668
3669
3670
3671
3672
3673
3674
3675
 
# File 'lib/aws-sdk-pipes/types.rb', line 3667

class UpdatePipeSourceSelfManagedKafkaParameters < Struct.new(
  :batch_size,
  :maximum_batching_window_in_seconds,
  :credentials,
  :server_root_ca_certificate,
  :vpc)
  SENSITIVE = []
  include Aws::Structure
end

#maximum_batching_window_in_seconds ⇒ Integer

The maximum length of a time to wait for events.

Returns:

  • (Integer) 


3667
3668
3669
3670
3671
3672
3673
3674
3675
 
# File 'lib/aws-sdk-pipes/types.rb', line 3667

class UpdatePipeSourceSelfManagedKafkaParameters < Struct.new(
  :batch_size,
  :maximum_batching_window_in_seconds,
  :credentials,
  :server_root_ca_certificate,
  :vpc)
  SENSITIVE = []
  include Aws::Structure
end

#server_root_ca_certificate ⇒ String

The ARN of the Secrets Manager secret used for certification.

Returns:

  • (String) 


3667
3668
3669
3670
3671
3672
3673
3674
3675
 
# File 'lib/aws-sdk-pipes/types.rb', line 3667

class UpdatePipeSourceSelfManagedKafkaParameters < Struct.new(
  :batch_size,
  :maximum_batching_window_in_seconds,
  :credentials,
  :server_root_ca_certificate,
  :vpc)
  SENSITIVE = []
  include Aws::Structure
end

#vpc ⇒ Types::SelfManagedKafkaAccessConfigurationVpc

This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.

Returns:



3667
3668
3669
3670
3671
3672
3673
3674
3675
 
# File 'lib/aws-sdk-pipes/types.rb', line 3667

class UpdatePipeSourceSelfManagedKafkaParameters < Struct.new(
  :batch_size,
  :maximum_batching_window_in_seconds,
  :credentials,
  :server_root_ca_certificate,
  :vpc)
  SENSITIVE = []
  include Aws::Structure
end