Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
T
trackrdrd
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
uplex-varnish
trackrdrd
Commits
d6de899a
Commit
d6de899a
authored
Feb 07, 2024
by
Geoff Simmons
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Get rid of a deprecated librdkafka function.
parent
d4913ef5
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
2 additions
and
3 deletions
+2
-3
mq.c
src/mq/kafka/mq.c
+1
-1
worker.c
src/mq/kafka/worker.c
+1
-2
No files found.
src/mq/kafka/mq.c
View file @
d6de899a
...
...
@@ -352,7 +352,7 @@ MQ_Send(void *priv, const char *data, unsigned len, const char *key,
if
(
rd_kafka_produce
(
wrk
->
topic
,
RD_KAFKA_PARTITION_UA
,
RD_KAFKA_MSG_F_FREE
,
payload
,
len
,
key
,
keylen
,
NULL
)
==
-
1
)
{
snprintf
(
wrk
->
errmsg
,
LINE_MAX
,
"%s"
,
rd_kafka_err2str
(
rd_kafka_
errno2err
(
errno
)));
rd_kafka_err2str
(
rd_kafka_
last_error
(
)));
MQ_LOG_Log
(
LOG_ERR
,
"%s message send failure (%d): %s"
,
rd_kafka_name
(
wrk
->
kafka
),
errno
,
wrk
->
errmsg
);
*
error
=
wrk
->
errmsg
;
...
...
src/mq/kafka/worker.c
View file @
d6de899a
...
...
@@ -93,10 +93,9 @@ const char
CHECK_OBJ_NOTNULL
((
kafka_wrk_t
*
)
rd_kafka_opaque
(
rk
),
KAFKA_WRK_MAGIC
);
rd_kafka_set_log_level
(
rk
,
loglvl
);
errno
=
0
;
rkt
=
rd_kafka_topic_new
(
rk
,
topic
,
wrk_topic_conf
);
if
(
rkt
==
NULL
)
{
rd_kafka_resp_err_t
rkerr
=
rd_kafka_
errno2err
(
errno
);
rd_kafka_resp_err_t
rkerr
=
rd_kafka_
last_error
(
);
snprintf
(
errmsg
,
LINE_MAX
,
"Failed to initialize topic: %s"
,
rd_kafka_err2str
(
rkerr
));
MQ_LOG_Log
(
LOG_ERR
,
errmsg
);
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment