Han-lai opened a new issue, #8053:
URL: https://github.com/apache/seatunnel/issues/8053

   ### Search before asking
   
   - [X] I had searched in the 
[issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22)
 and found no similar issues.
   
   
   ### What happened
   
    I am encountering a NullPointerException issue while working with the 
SeaTunnel Kafka connector. I believe this issue might be related to the 
incomplete implementation of metadata extraction, which was initially proposed 
in Issue #2755 by hailin0.
   
   In the proposal, there were several features outlined for improvement, such 
as:
   
   - Supporting the extraction of message metadata (e.g., key, timestamp, 
headers).
   - Extracting topics and partitions from SeaTunnelRow fields.
   
   Although PR #3501 has already addressed some of these aspects by supporting 
the extraction of metadata like the message key, timestamp, and headers, the 
full implementation, particularly the extraction of topics, partitions, and 
handling all metadata consistently, has not been completed.
   
   Given that the full extraction of metadata (including topic and partition 
information) has not been fully implemented, I suspect that the 
NullPointerException might be a result of missing metadata in the processing 
pipeline, especially when the connector attempts to access the topic and 
partition details.
   
   Could the team prioritize the completion of these features, particularly the 
extraction of topic, partition, and other metadata from SeaTunnelRow, and 
ensure that metadata is consistently handled when reading and writing Kafka 
messages? This would not only help resolve potential issues like the 
NullPointerException but also enhance the flexibility and efficiency of the 
Kafka connector for developers.
   
   
   
   ### SeaTunnel Version
   
   2.3.7
   
   ### SeaTunnel Config
   
   ```conf
   none
   ```
   
   
   ### Running Command
   
   ```shell
   "/bin/sh", "-c", "/opt/seatunnel/bin/seatunnel-cluster.sh"
   ```
   
   
   ### Error Exception
   
   ```log
   java.lang.RuntimeException: java.util.concurrent.ExecutionException: 
java.lang.NullPointerException
        at 
org.apache.seatunnel.engine.server.operation.GetJobMetricsOperation.run(GetJobMetricsOperation.java:87)
 ~[seatunnel-starter.jar:2.3.7]
        at 
com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) 
~[seatunnel-starter.jar:2.3.7]
        at 
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273)
 ~[seatunnel-starter.jar:2.3.7]
        ... (省略其他堆疊追蹤)
   Caused by: java.util.concurrent.ExecutionException: 
java.lang.NullPointerException
        at 
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) 
~[?:1.8.0_342]
        at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) 
~[?:1.8.0_342]
        at 
org.apache.seatunnel.engine.server.operation.GetJobMetricsOperation.run(GetJobMetricsOperation.java:85)
 ~[seatunnel-starter.jar:2.3.7]
        ... (省略其他堆疊追蹤)
   ```
   
   
   ### Zeta or Flink or Spark Version
   
   _No response_
   
   ### Java or Scala Version
   
   _No response_
   
   ### Screenshots
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@seatunnel.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to