Browse Source
Merge pull request #15768 from AndriiLandiak/merged-with-lts-4.2
Merged with lts 4.2
pull/15796/head
Viacheslav Klimov
4 months ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with
1 additions and
1 deletions
-
application/src/main/java/org/thingsboard/server/service/edge/rpc/KafkaEdgeGrpcSession.java
|
|
@ -74,7 +74,7 @@ public class KafkaEdgeGrpcSession extends EdgeGrpcSession { |
|
|
// where readiness flips during poll(), and that already-polled batch is dropped here (can't rewind).
|
|
|
// where readiness flips during poll(), and that already-polled batch is dropped here (can't rewind).
|
|
|
if (!isReadyToProcessGeneralEvents()) { |
|
|
if (!isReadyToProcessGeneralEvents()) { |
|
|
log.debug("[{}][{}] edge not connected, edge sync is not completed or high priority processing in progress, " + |
|
|
log.debug("[{}][{}] edge not connected, edge sync is not completed or high priority processing in progress, " + |
|
|
"connected = {}, sync in progress = {}, high priority in progress = {}. Skipping iteration", |
|
|
"connected = {}, sync in progress = {}, high priority in progress = {}. Skipping iteration", |
|
|
tenantId, edge.getId(), isConnected(), isSyncInProgress(), isHighPriorityProcessing); |
|
|
tenantId, edge.getId(), isConnected(), isSyncInProgress(), isHighPriorityProcessing); |
|
|
return; |
|
|
return; |
|
|
} |
|
|
} |
|
|
|