KEY:
audit_kafka[:name]  send audit logs to kafka endpoints

ARGS:
brokers*         (csv)       comma separated list of Kafka broker addresses
topic            (string)    Kafka topic used for bucket notifications
sasl_username    (string)    username for SASL/PLAIN or SASL/SCRAM authentication
sasl_password    (string)    password for SASL/PLAIN or SASL/SCRAM authentication

	"github.com/minio/minio/internal/store"
	"github.com/minio/pkg/v3/workers"
)

const (
	logSubsys = "notify"

	// The maximum allowed number of concurrent Send() calls to all configured notifications targets
	maxConcurrentAsyncSend = 50000
)

// Target - event target interface
type Target interface {
	ID() TargetID
	IsActive() (bool, error)
	Save(Event) error
	SendFromStore(store.Key) error

     */
    @Required
    @Size(max = 1000)
    public String id;

    /**
     * The version number of the scheduler for optimistic locking.
     * This field is required to prevent concurrent modification conflicts
     * by ensuring the scheduler hasn't been modified by another process.
     */
    @Required
    @ValidateTypeFailure
    public Integer versionNo;

Copyright ©2013 The gonum Authors. All rights reserved.

Redistribution and use in source and binary forms, with or without
modification, are permitted provided that the following conditions are met:
    * Redistributions of source code must retain the above copyright
      notice, this list of conditions and the following disclaimer.
    * Redistributions in binary form must reproduce the above copyright

Copyright <YEAR> <COPYRIGHT HOLDER>

Redistribution and use in source and binary forms, with or without
modification, are permitted provided that the following conditions
are met:

1. Redistributions of source code must retain the above copyright
notice, this list of conditions and the following disclaimer.

2. Redistributions in binary form must reproduce the above copyright
notice, this list of conditions and the following disclaimer in the

Copyright 2009 The Go Authors.

Redistribution and use in source and binary forms, with or without
modification, are permitted provided that the following conditions are
met:

   * Redistributions of source code must retain the above copyright
notice, this list of conditions and the following disclaimer.
   * Redistributions in binary form must reproduce the above
copyright notice, this list of conditions and the following disclaimer

= vendor/github.com/antlr4-go/antlr/v4 licensed under: =

Copyright (c) 2012-2023 The ANTLR Project. All rights reserved.

Redistribution and use in source and binary forms, with or without
modification, are permitted provided that the following conditions
are met:

1. Redistributions of source code must retain the above copyright
notice, this list of conditions and the following disclaimer.

 */
package jcifs.internal.witness;

/**
 * Represents a witness registration request as defined in MS-SWN specification.
 * Used to register for witness notifications from the witness service.
 */
public class WitnessRegisterRequest {
    /**
     * Creates a new witness register request.
     */
    public WitnessRegisterRequest() {
        // Default constructor
    }

import jcifs.internal.smb2.ServerMessageBlock2Response;
import jcifs.internal.util.SMBUtil;

/**
 * SMB2 Set Info response message. This response acknowledges the successful
 * modification of file or security information.
 *
 * @author mbechler
 *
 */
public class Smb2SetInfoResponse extends ServerMessageBlock2Response {

    /**

     */
    @ValidateTypeFailure
    public Long updatedTime;

    /**
     * The version number of the access token for optimistic locking.
     * This field is required to prevent concurrent modification conflicts
     * by ensuring the token hasn't been modified by another process.
     */
    @Required
    @ValidateTypeFailure
    public Integer versionNo;