Class: Aws::Pipes::Types::UpdatePipeSourceManagedStreamingKafkaParameters

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

Overview

The parameters for using an MSK stream as a source.

Constant Summary collapse

SENSITIVE =
[]

Instance Attribute Summary collapse

Instance Attribute Details

#batch_sizeInteger

The maximum number of records to include in each batch.

Returns:

  • (Integer)


3521
3522
3523
3524
3525
3526
3527
# File 'lib/aws-sdk-pipes/types.rb', line 3521

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

#credentialsTypes::MSKAccessCredentials

The credentials needed to access the resource.



3521
3522
3523
3524
3525
3526
3527
# File 'lib/aws-sdk-pipes/types.rb', line 3521

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

#maximum_batching_window_in_secondsInteger

The maximum length of a time to wait for events.

Returns:

  • (Integer)


3521
3522
3523
3524
3525
3526
3527
# File 'lib/aws-sdk-pipes/types.rb', line 3521

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