NvPSFKafka.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: Copyright (c) 2025 NVIDIA CORPORATION & AFFILIATES. All rights reserved.
 * SPDX-License-Identifier: LicenseRef-NvidiaProprietary
 *
 * NVIDIA CORPORATION, its affiliates and licensors retain all intellectual
 * property and proprietary rights in and to this material, related
 * documentation and any modifications thereto. Any use, reproduction,
 * disclosure or distribution of this material and related documentation
 * without an express license agreement from NVIDIA CORPORATION or
 * its affiliates is strictly prohibited.
*/
#ifndef NVPSF_KAFKA_H
#define NVPSF_KAFKA_H
 
#include <stddef.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef enum {
    NvPSFKAFKA_SUCCESS = 0,
    NvPSFKAFKA_FAIL = 1
} NvPSFKafkaErr;
 
typedef struct {
    NvPSFKafkaErr err;
    int retCode; // 0 for success, or error code
    size_t recvd_bytes; // For receive, number of bytes received
} NvPSFKafkaStatus;
 
typedef enum {
    KAFKA_PRODUCER = 0,
    KAFKA_CONSUMER = 1
} NvPSFKafkaEndpointType;
 
typedef struct NvPSFKafkaHandle_t NvPSFKafkaHandle;
 
NvPSFKafkaStatus NvPSFKafkaCreate(const char* brokers, const char* topic, NvPSFKafkaEndpointType endpointType, const char* group_id, NvPSFKafkaHandle** out_handle);
 
NvPSFKafkaStatus NvPSFKafkaDestroy(NvPSFKafkaHandle* handle);
 
NvPSFKafkaStatus NvPSFKafkaSend(NvPSFKafkaHandle* handle, const void* msg, size_t msgLen);
 
NvPSFKafkaStatus NvPSFKafkaReceive(NvPSFKafkaHandle* handle, void* buffer, size_t bufferLen, size_t* outLen);
 
NvPSFKafkaStatus NvPSFKafkaSeekToEnd(NvPSFKafkaHandle* handle);
 
#ifdef __cplusplus
}
#endif
 
#endif // NVPSF_KAFKA_H