Fix timestamp support detection (compile time)

(cherry picked from commit b5e6f16)
edenhill · Dec 17, 2016 · 0c6233d · 0c6233d
1 parent 0a2dd68
commit 0c6233d
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 16 deletions.
diff --git a/format.c b/format.c
@@ -132,9 +132,9 @@ void fmt_parse (const char *fmt) {
                         case 'p':
                                 fmt_add(KC_FMT_PARTITION, NULL, 0);
                                 break;
-			case 'T':
-				fmt_add(KC_FMT_TIMESTAMP, NULL, 0);
-				break;
+                        case 'T':
+                                fmt_add(KC_FMT_TIMESTAMP, NULL, 0);
+                                break;
                         case '%':
                                 fmt_add(KC_FMT_STR, s, 1);
                                 break;
@@ -241,19 +241,19 @@ static void fmt_msg_output_str (FILE *fp,
                         r = fprintf(fp, "%"PRId32, rkmessage->partition);
                         break;
 
-		case KC_FMT_TIMESTAMP:
-		{
-#ifdef RD_KAFKA_TIMESTAMP_CREATE_TIME
-			rd_kafka_timestamp_type_t tstype;
-			r = fprintf(fp, "%"PRId64,
-				    rd_kafka_message_timestamp(rkmessage,
-							       &tstype));
+#if RD_KAFKA_VERSION >= 0x000902ff
+                case KC_FMT_TIMESTAMP:
+                {
+                        rd_kafka_timestamp_type_t tstype;
+                        r = fprintf(fp, "%"PRId64,
+                                    rd_kafka_message_timestamp(rkmessage,
+                                                               &tstype));
 #else
-			r = fprintf(fp, "-1");
+                        r = fprintf(fp, "-1");
 #endif
-			break;
-		}
-		}
+                        break;
+                }
+                }
 
 
                 if (r < 1)

diff --git a/kafkacat.c b/kafkacat.c
@@ -904,8 +904,8 @@ static void __attribute__((noreturn)) usage (const char *argv0, int exitcode,
                 "                     as a binary big endian 32-bit signed integer\n"
                 "  %%k                 Message key\n"
                 "  %%K                 Message key length (or -1 for NULL)\n"
-#ifdef RD_KAFKA_TIMESTAMP_CREATE_TIME
-		"  %%T                 Message timestamp (milliseconds since epoch)\n"
+#if RD_KAFKA_VERSION >= 0x000902ff
+                "  %%T                 Message timestamp (milliseconds since epoch UTC)\n"
 #endif
                 "  %%t                 Topic\n"
                 "  %%p                 Partition\n"