ERROR 2025-05-06 11:00:25.382 DataCarrier.DEFAULT.Consumer.0.Thread KafkaTraceSegmentServiceClient : Failed to report TraceSegment. org.apache.skywalking.apm.dependencies.org.apache.kafka.common.errors.TimeoutException: Topic skywalking-segments not present in metadata after 60000 ms.

[hgaong]

agent log:
ERROR 2025-05-06 11:00:25.382 DataCarrier.DEFAULT.Consumer.0.Thread KafkaTraceSegmentServiceClient : Failed to report TraceSegment.
org.apache.skywalking.apm.dependencies.org.apache.kafka.common.errors.TimeoutException: Topic skywalking-segments not present in metadata after 60000 ms.

kafka :

why ? thx

[wu-sheng]

This seems to be your Kafka status issue? We don't have enough knowledge for Kafka support.

[hgaong]

agent report topic skywalking-segments ,but skywalking oap server init topic skywalking-segments-0 ,

[hgaong]

Why are their topic names different

[wu-sheng]

skywalking/oap-server/server-fetcher-plugin/kafka-fetcher-plugin/src/main/java/org/apache/skywalking/oap/server/analyzer/agent/kafka/provider/handler/AbstractKafkaHandler.java

Lines 34 to 47 in 889ae9d

	public String getTopic() {
	StringBuilder sb = new StringBuilder();
	if (StringUtils.isNotBlank(config.getMm2SourceAlias())) {
	sb.append(config.getMm2SourceAlias()).append(config.getMm2SourceSeparator());
	}
	if (StringUtil.isNotBlank(config.getNamespace())) {
	sb.append(config.getNamespace()).append("-");
	}
	sb.append(getPlainTopic());
	return sb.toString();
	}
	protected abstract String getPlainTopic();

Check here, we don't create any suffix.

[wu-sheng]

AFAIK, that is just a partition suffix. Please check kafka docs. I don't know much about it.