2023-07-07 00:56:56,337 - [ERROR] - from kafka.manager.actor.cluster.KafkaStateActor in kafka-manager-system-akka.actor.default-dispatcher-11 KafkaTopicOffsetGetter exception java.util.NoSuchElementException: key not found: PLAINTEXT at scala.collection.immutable.Map
M
a
p
1.
a
p
p
l
y
(
M
a
p
.
s
c
a
l
a
:
114
)
a
t
k
a
f
k
a
.
m
a
n
a
g
e
r
.
a
c
t
o
r
.
c
l
u
s
t
e
r
.
K
a
f
k
a
S
t
a
t
e
A
c
t
o
r
Map1.apply(Map.scala:114) at kafka.manager.actor.cluster.KafkaStateActor
Map1.apply(Map.scala:114)atkafka.manager.actor.cluster.KafkaStateActorKafkaTopicOffsetGetter.
a
n
o
n
f
u
n
anonfun
anonfunrun
22
(
K
a
f
k
a
S
t
a
t
e
A
c
t
o
r
.
s
c
a
l
a
:
1492
)
a
t
k
a
f
k
a
.
m
a
n
a
g
e
r
.
a
c
t
o
r
.
c
l
u
s
t
e
r
.
K
a
f
k
a
S
t
a
t
e
A
c
t
o
r
22(KafkaStateActor.scala:1492) at kafka.manager.actor.cluster.KafkaStateActor
22(KafkaStateActor.scala:1492)atkafka.manager.actor.cluster.KafkaStateActorKafkaTopicOffsetGetter.
a
n
o
n
f
u
n
anonfun
anonfunrun
22
22
22adapted(KafkaStateActor.scala:1484) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach
(
I
t
e
r
a
t
o
r
.
s
c
a
l
a
:
941
)
a
t
s
c
a
l
a
.
c
o
l
l
e
c
t
i
o
n
.
A
b
s
t
r
a
c
t
I
t
e
r
a
t
o
r
.
f
o
r
e
a
c
h
(
I
t
e
r
a
t
o
r
.
s
c
a
l
a
:
1429
)
a
t
s
c
a
l
a
.
c
o
l
l
e
c
t
i
o
n
.
M
a
p
L
i
k
e
(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.MapLike
(Iterator.scala:941)atscala.collection.AbstractIterator.foreach(Iterator.scala:1429)atscala.collection.MapLikeDefaultKeySet.foreach(MapLike.scala:181) at kafka.manager.actor.cluster.KafkaStateActor
K
a
f
k
a
T
o
p
i
c
O
f
f
s
e
t
G
e
t
t
e
r
.
KafkaTopicOffsetGetter.
KafkaTopicOffsetGetter.anonfun$run
21
(
K
a
f
k
a
S
t
a
t
e
A
c
t
o
r
.
s
c
a
l
a
:
1484
)
a
t
s
c
a
l
a
.
u
t
i
l
.
c
o
n
t
r
o
l
.
B
r
e
a
k
s
.
b
r
e
a
k
a
b
l
e
(
B
r
e
a
k
s
.
s
c
a
l
a
:
42
)
a
t
k
a
f
k
a
.
m
a
n
a
g
e
r
.
a
c
t
o
r
.
c
l
u
s
t
e
r
.
K
a
f
k
a
S
t
a
t
e
A
c
t
o
r
21(KafkaStateActor.scala:1484) at scala.util.control.Breaks.breakable(Breaks.scala:42) at kafka.manager.actor.cluster.KafkaStateActor
21(KafkaStateActor.scala:1484)atscala.util.control.Breaks.breakable(Breaks.scala:42)atkafka.manager.actor.cluster.KafkaStateActorKafkaTopicOffsetGetter.
a
n
o
n
f
u
n
anonfun
anonfunrun
17
(
K
a
f
k
a
S
t
a
t
e
A
c
t
o
r
.
s
c
a
l
a
:
1484
)
a
t
k
a
f
k
a
.
m
a
n
a
g
e
r
.
a
c
t
o
r
.
c
l
u
s
t
e
r
.
K
a
f
k
a
S
t
a
t
e
A
c
t
o
r
17(KafkaStateActor.scala:1484) at kafka.manager.actor.cluster.KafkaStateActor
17(KafkaStateActor.scala:1484)atkafka.manager.actor.cluster.KafkaStateActorKafkaTopicOffsetGetter.
a
n
o
n
f
u
n
anonfun
anonfunrun
17
17
17adapted(KafkaStateActor.scala:1452) at scala.Option.fold(Option.scala:251) at kafka.manager.actor.cluster.KafkaStateActor$KafkaTopicOffsetGetter.run(KafkaStateActor.scala:1452) at java.base/java.lang.Thread.run(Thread.java:834)
