Bitquery's Kafka stream TRON block monitoring

Please don't use AI-generated code like GPT and Claude to fool me！！！！！！！！

You need to understand the documentation of the Bitquery platform and then help me write a script.

I need a sample demonstration code based on Node.js to implement Kafka.

The function I need to implement is: After startup, listen for and print out the following events.

Analyze the TRX transfer transaction and print it out.
The print format is as follows:
[TRX Transaction Activity]
Transaction Hash: xxx
Block Number: xxx
Sender Address: xxx
Receiver Address: xxx
Transaction Amount: xxx TRX
Transaction Time: xxx



2. Analyze the TRX staking transaction event and print it out.
[TRX Staking Transaction Event]
Transaction Hash: xxx
Block Number: xxx
Staking Address: xxx
Staking Amount: xxx TRX
Transaction Time: xxx

[TRX Unstake Transaction Event]
Transaction Hash: xxx
Block Number: xxx
Unstake Address: xxx
Unstake Amount: xxx TRX
Transaction Time: xxx

3. Analyze the USDT transfer transaction event and print it out [transferFrom (23b872dd) + transfer (a9059cbb)]
[USDT Transfer Transaction Event]
Transaction Hash: xxx
Block Number: xxx
Sender Address: xxx
Recipient Address: xxx
Transaction Amount: xxx USDT
Transaction Time: xxx

4. Analyze the USDT authorization transaction events and print out [approve (095ea7b3) + increaseApproval (d73dd623) + decreaseApproval (66188463)]
[USDT Authorization Transaction Events]
Transaction Hash: xxx
Block Number: xxx
Authorization Initiator Address: xxx
Authorized Address: xxx
Authorized Amount: xxx USDT
Transaction Time: xxx



5. Analyze the multi-signature transaction events of the wallet and print them out.
[Multi-signature Transaction Event]
Transaction Hash: xxx
Block Number: xxx
Multi-signature Initiator Address: xxx
Authorized To: xxx
Permission Name: xxx
Operation(s): xxx
Threshold: xxx
Weight: xxx Trading time: xxx




6. Analyze the energy sending transaction event and print it out.
[Energy Sending Transaction Event]
Transaction Hash: xxx
Block Number: xxx
Energy Sending Address: xxx
Energy Receiving Address: xxx
Energy Sent Quantity: xxx
Transaction Time: xxx



7. Analyze the energy recovery transaction event and print it out
[Energy sending transaction event]
Transaction hash: xxx
Block number: xxx
Initiating transaction address: xxx
Energy recovery address: xxx
Recovery energy quantity: xxx
Transaction time: xxx





8. Analyze the broadband sending transaction event and print it out
[Broadband Sending Transaction Event]
Transaction Hash: xxx
Block Number: xxx
Broadband Sending Address: xxx
Broadband Receiving Address: xxx
Sent Broadband Quantity: xxx
Transaction Time: xxx



9. Analyze the broadband recycling transaction event and print it out
[Broadband sending transaction event]
Transaction hash: xxx
Block number: xxx
Initiating transaction address: xxx
Broadband recycling address: xxx
Recycled energy broadband: xxx
Transaction time: xxx