From 2447b7c16739ac44aa19395a5f52c9ddbf928e9a Mon Sep 17 00:00:00 2001
From: Jay Ehsaniara <ehsaniara@gmail.com>
Date: Sat, 19 Jun 2021 18:01:39 -0700
Subject: [PATCH] Update KafkaStreamsInteractiveQuerySample.java

Avro generates primitive long in the later versions
---
 .../interactive/query/KafkaStreamsInteractiveQuerySample.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/java/kafka/streams/interactive/query/KafkaStreamsInteractiveQuerySample.java b/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/java/kafka/streams/interactive/query/KafkaStreamsInteractiveQuerySample.java
index 93e82e6..2f29acf 100644
--- a/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/java/kafka/streams/interactive/query/KafkaStreamsInteractiveQuerySample.java
+++ b/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/java/kafka/streams/interactive/query/KafkaStreamsInteractiveQuerySample.java
@@ -322,11 +322,11 @@ public class KafkaStreamsInteractiveQuerySample {
 	static class TopFiveSongs implements Iterable<SongPlayCount> {
 		private final Map<Long, SongPlayCount> currentSongs = new HashMap<>();
 		private final TreeSet<SongPlayCount> topFive = new TreeSet<>((o1, o2) -> {
-			final int result = o2.getPlays().compareTo(o1.getPlays());
+			final int result = Long.compare(o2.getPlays(), o1.getPlays());
 			if (result != 0) {
 				return result;
 			}
-			return o1.getSongId().compareTo(o2.getSongId());
+			return Long.compare(o1.getSongId(), o2.getSongId());
 		});
 
 		public void add(final SongPlayCount songPlayCount) {