KafkaSettings.fromJson constructor

KafkaSettings.fromJson(
  1. Map<String, dynamic> json
)

Implementation

factory KafkaSettings.fromJson(Map<String, dynamic> json) {
  return KafkaSettings(
    broker: json['Broker'] as String?,
    includeControlDetails: json['IncludeControlDetails'] as bool?,
    includeNullAndEmpty: json['IncludeNullAndEmpty'] as bool?,
    includePartitionValue: json['IncludePartitionValue'] as bool?,
    includeTableAlterOperations: json['IncludeTableAlterOperations'] as bool?,
    includeTransactionDetails: json['IncludeTransactionDetails'] as bool?,
    messageFormat: (json['MessageFormat'] as String?)?.toMessageFormatValue(),
    messageMaxBytes: json['MessageMaxBytes'] as int?,
    partitionIncludeSchemaTable: json['PartitionIncludeSchemaTable'] as bool?,
    topic: json['Topic'] as String?,
  );
}