MINOR: fix invalid usage in java docs

server-common/src/main/java/org/apache/kafka/server/util/Scheduler.java

@@ -50,7 +50,7 @@ default ScheduledFuture<?> scheduleOnce(String name, Runnable task, long delayMs
      * @param name The name of this task
      * @param task The task to run
      * @param delayMs The number of milliseconds to wait before the first execution
-     * @param periodMs The period in milliseconds with which to execute the task. If < 0 the task will execute only once.
+     * @param periodMs The period in milliseconds with which to execute the task. If &lt; 0 the task will execute only once.
      * @return A Future object to manage the task scheduled.
      */
     ScheduledFuture<?> schedule(String name, Runnable task, long delayMs, long periodMs);

streams/src/main/java/org/apache/kafka/streams/query/Position.java

@@ -57,7 +57,7 @@ public static Position emptyPosition() {
     }
 
     /**
-     * Create a new Position and populate it with a mapping of topic -> partition -> offset.
+     * Create a new Position and populate it with a mapping of topic -> partition -> offset.
      * <p>
      * Note, the resulting Position does not share any structure with the provided map, so
      * subsequent changes to the map or Position will not affect the other.
@@ -95,7 +95,7 @@ public Position copy() {
     /**
      * Merges the provided Position into the current instance.
      * <p>
-     * If both Positions contain the same topic -> partition -> offset mapping, the resulting
+     * If both Positions contain the same topic -&gt; partition -&gt; offset mapping, the resulting
      * Position will contain a mapping with the larger of the two offsets.
      */
     public Position merge(final Position other) {
@@ -127,7 +127,7 @@ public Set<String> getTopics() {
     }
 
     /**
-     * Return the partition -> offset mapping for a specific topic.
+     * Return the partition -&gt; offset mapping for a specific topic.
      */
     public Map<Integer, Long> getPartitionPositions(final String topic) {
         final ConcurrentHashMap<Integer, Long> bound = position.get(topic);