Skip to content

Commit 937e721

Browse files
author
and.sergeev
committed
removed obsolete code and added sync api for producer
1 parent 84b970f commit 937e721

File tree

9 files changed

+294
-736
lines changed

9 files changed

+294
-736
lines changed

docker/Dockerfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,4 +6,4 @@ ADD . /opt/tarantool
66

77
WORKDIR /opt/tarantool
88

9-
ENTRYPOINT tarantool /opt/tarantool/tests/new_producer.lua
9+
ENTRYPOINT tarantool /opt/tarantool/tests/producer.lua

kafka/config.lua

Lines changed: 0 additions & 160 deletions
This file was deleted.

kafka/librdkafka.lua

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ ffi.cdef[[
2121
void *key;
2222
size_t key_len;
2323
int64_t offset;
24+
void *_private;
2425
} rd_kafka_message_t;
2526

2627
typedef enum rd_kafka_type_t {

0 commit comments

Comments
 (0)