X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Flib%2Fgscprts%2Frts_kafka.c;fp=src%2Flib%2Fgscprts%2Frts_kafka.c;h=4e3eda4194f3dfec900be0fc0af2f9c04e66ab1d;hb=dec9c93423775db0f4783a93145f016d5d780ffd;hp=31049e55726ae011d7df1f583c179d8a8b122c17;hpb=a3f38475d1e9340f916140f4cf70221908cdff72;p=com%2Fgs-lite.git

diff --git a/src/lib/gscprts/rts_kafka.c b/src/lib/gscprts/rts_kafka.c
index 31049e5..4e3eda4 100644
--- a/src/lib/gscprts/rts_kafka.c
+++ b/src/lib/gscprts/rts_kafka.c
@@ -167,6 +167,7 @@ static gs_retval_t kafka_replay_init(gs_sp_t device)
 	gs_sp_t	verbosetmp;
 	gs_sp_t	delaytmp;
 	gs_sp_t	tempdel;
+	gs_sp_t	maxfieldtmp;	
 
 	if ((verbosetmp=get_iface_properties(device,(gs_sp_t)"verbose"))!=0) {
 		if (strncmp(verbosetmp,"TRUE",4)==0) {
@@ -195,11 +196,15 @@ static gs_retval_t kafka_replay_init(gs_sp_t device)
 
 	if ((delaytmp=get_iface_properties(device,(gs_sp_t)"startupdelay"))!=0) {
 		if (verbose) {
-				fprintf(stderr,"Startup delay of %u seconds\n",atoi(get_iface_properties(device,(gs_sp_t)"startupdelay")));
+				fprintf(stderr,"Startup delay of %u seconds\n",atoi(delaytmp));
 		}
-		startupdelay=atoi(get_iface_properties(device,(gs_sp_t)"startupdelay"));
+		startupdelay=atoi(delaytmp);
 	}
 
+	if ((maxfieldtmp=get_iface_properties(device,(gs_sp_t)"_max_csv_pos"))!=0) {
+		max_field_kafka=atoi(maxfieldtmp);
+	}	
+
 	// set maximum field nubmer to be extracted by csv parser
 	csv_set_maxfield(max_field_kafka);