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

Inherits:

Struct

• Object
• Struct
• Aws::Pipes::Types::UpdatePipeSourceSelfManagedKafkaParameters

Defined in:

gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb

Overview

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

See Also:

• AWS API Documentation

Constant Summary

SENSITIVE =

[]

Instance Attribute Summary

• #batch_size ⇒ Integer

  The maximum number of records to include in each batch.

• #credentials ⇒ Types::SelfManagedKafkaAccessConfigurationCredentials

  The credentials needed to access the resource.

• #maximum_batching_window_in_seconds ⇒ Integer

  The maximum length of a time to wait for events.

• #server_root_ca_certificate ⇒ String

  The ARN of the Secrets Manager secret used for certification.

• #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.

Instance Attribute Details

#batch_size ⇒ Integer

The maximum number of records to include in each batch.

Returns:

• (Integer)

# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3375

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

#credentials ⇒ Types::SelfManagedKafkaAccessConfigurationCredentials

The credentials needed to access the resource.

Returns:

• (Types::SelfManagedKafkaAccessConfigurationCredentials)

# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3375

class UpdatePipeSourceSelfManagedKafkaParameters < Struct.new(
  :batch_size,
  :credentials,
  :maximum_batching_window_in_seconds,
  :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)

# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3375

class UpdatePipeSourceSelfManagedKafkaParameters < Struct.new(
  :batch_size,
  :credentials,
  :maximum_batching_window_in_seconds,
  :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)

# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3375

class UpdatePipeSourceSelfManagedKafkaParameters < Struct.new(
  :batch_size,
  :credentials,
  :maximum_batching_window_in_seconds,
  :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:

• (Types::SelfManagedKafkaAccessConfigurationVpc)

# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 3375

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