Andre Lorbach 0d8f02b87e omkafka: When Timestamp was NULL, wrong dynamic timestamp was used.
Setting timestamp to 0 now lets kafka handle this.
Also added "RD_KAFKA_V_KEY(NULL,0) if no key is configured.

testbench: Changed kafka server configuration "log.retention.hours"
property to 5000 which avoids that the log cleaner is deleting our
records before they can be processed.
2018-09-06 09:59:45 +02:00
..