761ecb859f
Fixed typos in printouts
2014-08-26 07:47:22 +02:00
21c30290b6
Sparse metadata retrieval mode (consumes less bandwidth) (issue #138 )
...
Config property: topic.metadata.refresh.sparse = true or false
Defaults to false (old behaviour)
2014-08-25 15:30:08 +02:00
ded2f27b6a
Test synch fix
2014-08-25 15:27:09 +02:00
c52ac9f563
Dynamic topic naming in unit-tests
2014-08-25 15:26:58 +02:00
d424a13453
Added "protocol" debugging (sent and received message types)
2014-08-21 21:49:57 +02:00
78093541b5
0.8.4 versioning
2014-08-18 11:47:20 +02:00
d428a4b771
Use .dylib extension on OSX
2014-08-15 10:04:36 +02:00
8a918b29fb
Fixed SYMDUMPER on OSX
2014-08-15 10:03:35 +02:00
bc0380cafb
RD_KAFKA_OFFSET_TAIL() no longer messes up Offset requests (issue #136 )
2014-08-13 21:44:01 +02:00
7b23fa4d07
Protect from corrupt metadata (unknown partitions, issue #132 )
2014-08-04 18:23:18 +02:00
a090c73091
Initialize Conf object members (issue #125 )
2014-08-02 10:50:40 +02:00
f2509e301e
Allow Conf object reuse in C++ interface
2014-08-02 10:50:24 +02:00
0ea0b29fc9
produce_batch(): Fixed race condition when cluster comes up
...
If rdkafka is connecting to the cluster for the first time at the same
time as a larger batch is produced the message batch may end up
stuck in the Unassigned partition queue.
2014-07-30 23:32:20 +02:00
977f3b2ce1
Added produce->consume test (produce batch, consumer queues, TAIL)
2014-07-30 23:32:20 +02:00
fdb69ce598
Added RD_KAFKA_OFFSET_TAIL(cnt) to start consuming 'cnt' messages from end.
...
An application can now easily consume the last 'cnt' messages from a partition.
2014-07-30 23:32:20 +02:00
c41b8a34f0
Added "unique" test ids for message validation
2014-07-30 23:32:20 +02:00
2e769153fe
Added consumer queue rerouting
...
This allows the application to consume from multiple topic+partitions
with a single rd_kafka_consume*() call, instead of one such
call per topic+partition.
2014-07-30 23:32:20 +02:00
a923791bf1
WIP: Added consumer queue rerouting
...
This allows the application to consume from multiple topic+partitions
with a single rd_kafka_consume*() call, instead of one such
call per topic+partition.
2014-07-30 23:32:20 +02:00
ad5d05d320
Topics were not destroyed in example code (issue #130 )
2014-07-27 16:37:56 +02:00
67d38960f9
Initialize rkb_lock
2014-07-20 22:16:14 +02:00
13f731d4dd
Merge pull request #127 from liyujun/patch-1
...
Fix gcc 4.1 compiler warning: value not used (patch from liyujun)
2014-07-13 09:31:57 +02:00
a1d8412bee
Update rdkafka_msg.c
...
gcc version 4.1.2 20080704 (Red Hat 4.1.2-44)
$[home/kafka/librdkafka-master] make all
gcc -MD -MP -g -O2 -fPIC -Wall -Werror -Wfloat-equal -Wpointer-arith -c rdkafka_msg.c -o rdkafka_msg.o
cc1: warnings being treated as errors
rdkafka_msg.c: In function 'rd_kafka_msg_new':
rdkafka_msg.c:137: warning: value computed is not used
make: *** [rdkafka_msg.o] Error 1
rdkafka_msg.c:137 : 'rd_atomic_sub(&rkt->rkt_rk->rk_producer.msg_cnt, 1);' and '(void)'
2014-07-13 15:26:51 +08:00
094ae5c44e
Fix lock-order dead-lock on metadata updates
2014-07-06 23:41:57 +02:00
1ade4c90e4
Proper locking for rktp_metadata
2014-07-06 23:41:57 +02:00
15d8ae3cd3
msg_cb comment
2014-07-06 23:41:57 +02:00
8653b009fc
Removed unused rk_kafka_t.rk_err (512 bytes)
2014-07-06 23:41:57 +02:00
ef015c5f41
Remove -gstrict-dwarf from examples/ CPPFLAGS (for OSX 10.9)
2014-06-26 23:44:32 +02:00
58f7e76160
Merge pull request #126 from xhcqwlgithub/master
...
Added constructor for ConfImpl
2014-06-25 13:34:19 +02:00
385ea95242
Update rdkafkacpp_int.h
...
fix the bug when creating producer with default callback functions
2014-06-25 13:41:29 +08:00
8afdbe0dda
Added link to Hermann
2014-06-17 00:37:57 +02:00
e5d6e4dd18
Updated README
2014-06-16 23:06:17 +02:00
c3dc4744fe
Added produce.offset.report to propagate message offset back to producer application
2014-06-16 14:54:05 +02:00
84a12a1974
mklove update: fixes compiles on osx 10.9 (issue #49 )
2014-06-14 23:43:20 +02:00
d278f553ed
Dont log decode errors in Fetch replies since they are most likely partial messages, which are okay
2014-06-11 22:36:15 +02:00
f7e914e5b4
Added missing ERR__ISR_INSUFF in C++ interface
2014-06-11 22:09:41 +02:00
78b40fdb5e
Added Consumer/Producer info to CONFIGURATION.md
2014-06-11 22:09:41 +02:00
c484262f02
Dont hide symbols in C++ library (issue #95 )
2014-06-10 17:02:35 +02:00
5d8d4f0186
Dont print error log on receiving partial messages (issue #122 )
...
This also adds a counter (broker.rxpartial) for partial messages.
2014-06-08 23:12:16 +02:00
6be473a361
mklove update for ARFLAGS
2014-06-04 23:22:56 +02:00
b7f3c6c7af
Aesthetic fixes to silence Sun Studio compiler
2014-06-04 23:22:56 +02:00
b810eeae3d
Provide broker state age ("stateage") in stats and dump output
2014-06-04 11:51:14 +02:00
de2ee7361f
Default socket.max.fails to 3 (not 0)
2014-06-04 11:50:21 +02:00
0be5ee2c51
Merge pull request #121 from cosbynator/master
...
Add typedefs for metadata structs
2014-06-01 10:22:03 +02:00
e169142852
Add typedefs for metadata structs
2014-06-01 00:05:07 -07:00
9174a04b5b
Merge pull request #120 from eugpermar/master
...
Fix bad configuration name in doc
2014-05-27 12:53:43 +02:00
0483329b2b
FIX: bad configuration name in doc
2014-05-27 10:48:25 +00:00
56be236395
Adjustment to socket.max.fails threshold
2014-05-22 14:59:47 +02:00
e9f4d9e256
Added config property socket.max.fails to disconnect from broker on request timeouts
2014-05-22 14:56:50 +02:00
ced7e54ce6
Added configuration property socket.keepalive.enable (enable SO_KEEPALIVE)
2014-05-22 14:55:58 +02:00
4cd83032e8
mklove update
2014-05-22 14:11:22 +02:00
Magnus Edenhill
liyujun
xhcqwlgithub
Thomas Dimson
Eugenio Pérez