Skip to content

Commit 6fc66c3

Browse files
committed
fix #23:NPE when source data in kafka is not partitioned and without key
1 parent edf9f95 commit 6fc66c3

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

jetstream-messaging/src/main/java/com/ebay/jetstream/event/channel/kafka/PartitionReader.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -317,9 +317,12 @@ public List<JetstreamEvent> readEvents() throws OffsetOutOfRangeException {
317317
Message message = messageAndOffset.message();
318318
ByteBuffer k = message.key();
319319
ByteBuffer p = message.payload();
320-
byte[] key = new byte[k.limit()];
320+
byte[] key = null;
321+
if (k != null) {
322+
key = new byte[k.limit()];
323+
k.get(key);
324+
}
321325
byte[] payload = new byte[p.limit()];
322-
k.get(key);
323326
p.get(payload);
324327
JetstreamEvent event = m_serializer
325328
.decode(key, payload);

0 commit comments

Comments
 (0)