Skip to content

IGNITE-25309 Compilation fix after IGNITE-15803, IGNITE-24786, IGNITE…#307

Open
maksaska wants to merge 2 commits intoapache:masterfrom
maksaska:ignite-25309
Open

IGNITE-25309 Compilation fix after IGNITE-15803, IGNITE-24786, IGNITE…#307
maksaska wants to merge 2 commits intoapache:masterfrom
maksaska:ignite-25309

Conversation

@maksaska
Copy link
Contributor

@maksaska maksaska commented May 6, 2025

…-24846

Map<TopicPartition, Long> offsets0 = cnsmr.endOffsets(parts, Duration.ofMillis(kafkaReqTimeout));

if (!F.isEmpty(offsets0) && F.eqNotOrdered(offsets, offsets0)) {
if (!F.isEmpty(offsets0) && eqNotOrdered(offsets, offsets0)) {
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

can be replaced with offsets0.equals(offsets)?

package org.apache.ignite.cdc.kafka;

import java.time.Duration;
import java.util.Collection;
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

unused import

import org.apache.ignite.cdc.TypeMapping;
import org.apache.ignite.internal.binary.BinaryContext;
import org.apache.ignite.internal.binary.BinaryMetadata;
import org.apache.ignite.internal.binary.BinaryUtils;
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

unused import

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants