8988df836d
Allow producing and consuming empty messages (issue #60 )
2014-01-15 22:14:38 +07:00
42287a4b82
snappy clang compilation fix
2014-01-15 22:00:01 +07:00
f39a340eb9
The application no longer needs to ignore SIGPIPE
2014-01-15 21:56:25 +07:00
9d303abbef
Added consumer offset management (local file)
2014-01-15 21:56:25 +07:00
f38e0e2916
Added simple timers
2014-01-15 21:56:25 +07:00
1de5ed3c20
Log OP_ERR right away, without need for poll, if no error_cb is set.
2014-01-15 21:56:25 +07:00
43fa3adf18
Added salebab's phpkafka to list of users
2014-01-15 21:56:25 +07:00
d7d1695cf4
examples: Added support for canonical "end","beginning","stored" to -o offset arg
2014-01-15 21:56:25 +07:00
fc65a56d52
rdkafka_example: Added -X prop=val
2014-01-15 21:56:25 +07:00
72da05212a
rdkafka_performance: -X topic... properties did not work
2014-01-15 21:56:25 +07:00
ae11db745c
Fix .so file generation error introduced lately
2014-01-15 09:53:18 +07:00
9c9c8b0a57
Merge pull request #58 from dvanliere/master
...
Two minor fixes to improve bash scripts on OSX.
2014-01-09 14:20:52 -08:00
975caa0234
Use cross-platform compatible shell color codes.
2014-01-09 22:22:29 +01:00
94aa9cb349
Deprecate uname -o as that is a non-standard option.
...
Use the platform compatible uname -s option, see also
http://en.wikipedia.org/wiki/Uname for a nice overview of
interaction of options and platforms.
2014-01-09 22:20:13 +01:00
80a9d7a1fc
Merge pull request #57 from stromnet/master
...
RHEL (CentOS) 5 compilation fixes
2014-01-09 08:45:54 -08:00
b5b0b724f6
RHEL 5 does not have htole16/le32toh
...
These are from RHEL 6 endian.h
2014-01-09 17:30:39 +01:00
f5999b4ea4
RHEL 5 does not have TAILQ_CONCAT
...
rdkafka.c includes rdkafka_int.h which uses TAILQ_CONCAT. Added rdsysqueue.h include to fix
2014-01-09 17:30:39 +01:00
71f7310ead
RHEL 5 complains on "warning: value computed is not used"
2014-01-09 17:30:36 +01:00
730b155037
Disable valgrind tests
2014-01-09 00:36:20 +01:00
b99e3575a0
Fixed decoding of snappy-java compression framing (issue #55 )
2014-01-09 00:36:11 +01:00
7a01ba5995
rdkafka_performance: only dump rdkafka internal info if -d .. is enabled
2014-01-09 00:33:34 +01:00
e9948daf89
Added Produbans log2kafka to list of users
2014-01-08 20:21:04 +01:00
3669be01a5
Fixed flaky Gzip decompression (issue #54 )
2014-01-08 00:17:28 +01:00
6ff1307943
Merge pull request #53 from vadimg/master
...
get rid of warnings in gcc 4.4.3
2014-01-07 12:38:19 -08:00
1defe232e5
get rid of warnings in gcc 4.4.3
2014-01-07 15:26:59 -05:00
da19931722
Dont use modern 'install' flags (-t) (issue #49 )
2014-01-07 16:01:49 +01:00
7966ac1e05
Build .so file on Cygwin
2014-01-07 16:01:48 +01:00
eabdac80d4
Merge pull request #52 from edenhill/cygwin
...
Compile fixes for Cygwin (issue #25 )
2014-01-07 06:43:18 -08:00
6f15aa56e9
Compile fixes for Cygwin
2014-01-07 15:29:49 +01:00
8b655b9878
Clarified comments and function argument names.
2014-01-05 00:25:52 +01:00
a4b4b66579
Changed msgtimeout test to unknown partition test (issue #39 )
...
The way msgtimeout test was implemented will not work any more with
the fix for issue #39
2014-01-05 00:25:52 +01:00
b8d9f433d7
Fail messages for unknown partitions immediately (issue #39 )
...
Two error paths:
- produce() will fail with errno set to ESRCH
- dr_cb() will provide err RD_KAFKA_RESP_ERR__UNKNOWN_PARTITTION
2014-01-05 00:25:52 +01:00
1c8a448a8f
Clarify available compression support (none, gzip, snappy)
2014-01-04 21:51:20 +01:00
5783140ecf
Merge pull request #51 from dvanliere/master
...
Librdkafka now compiles on OSX 10.9
2014-01-04 12:09:38 -08:00
2a1952e8d0
Librdkafka now compiles on OSX 10.9
...
Refactored endian support to seperate file called endian_compat.h
that will fix two implicit declaration of function errors. Also
fixed a whole bunch of use of GNU old-style field designator
extension errors
2014-01-04 20:17:11 +01:00
80ef789359
Allow NULL 'conf' argument to rd_kafka_topic_new()
2014-01-01 23:27:11 +01:00
1854440829
Use 'void *' for produce payload type instead of 'char *'
...
This avoids the need for casting in the application.
2014-01-01 23:26:53 +01:00
d25d78228b
rdkafka_performance: Count immediate produce() failures as failed messages too
2014-01-01 23:26:07 +01:00
11b2bef3ac
Fixed typo in example programs (issue #44 )
2014-01-01 23:25:30 +01:00
2969ff08a0
Updated README on Debian packages and C++
2013-12-28 19:58:06 +01:00
b87cb412db
Added -I (idle) switch to rdkafka_performance
...
The Idle switch turns off producing any messages.
2013-12-28 00:48:07 +01:00
3436ef3208
Fixed output typo in rdkafka_performance
2013-12-28 00:33:53 +01:00
a52f58546e
Handle per topic+partition produce errors (issue #40 )
...
Produce errors were previously only handled if the entire request failed.
2013-12-28 00:21:43 +01:00
20e1b937ee
Const casting to make g++ happy (issue #36 )
2013-12-27 23:20:10 +01:00
119711c2c2
CONFIGURATION.md regen (statistics.interval.ms description update)
2013-12-20 09:15:12 +01:00
34c95f259c
Print error string, not number, in metadata request failure log message
2013-12-20 09:14:20 +01:00
ab803760ca
Only generate statistics if statistics.interval.ms is non-zero
...
Reported by Eugenio Peréz Martín
2013-12-16 15:04:19 +01:00
180d7d9144
Removed debug-assert from last commit.
2013-12-16 12:23:15 +01:00
16915a2855
Correctly calculate number of topics for filtered Metadata requests
...
Reported by Steven Le Roux
2013-12-14 23:11:28 +01:00
330b93f4ef
Fixed typo in INTRODUCTION
2013-12-06 13:36:18 +01:00
Magnus Edenhill
Diederik van Liere
Johan Ström
Vadim Graboys