@@ -59,32 +59,41 @@ Config is specified via the plugin's JSON config file.
5959 "request.required.acks" : " 1" ,
6060 "message.timeout.ms" : " 30000" ,
6161 "compression.type" : " lz4" ,
62- "partitioner" : " murmur2_random"
62+ "partitioner" : " murmur2_random" ,
63+ "statistics.interval.ms" : " 1000"
6364 },
6465 "shutdown_timeout_ms" : 30000 ,
65- "update_account_topic" : " solana.testnet.account_updates" ,
66- "slot_status_topic" : " solana.testnet.slot_status" ,
67- "transaction_topic" : " solana.testnet.transactions" ,
68- "publish_all_accounts" : false ,
69- "wrap_messages" : false ,
70- "program_ignores" : [
71- " Sysvar1111111111111111111111111111111111111" ,
72- " Vote111111111111111111111111111111111111111"
73- ]
66+ "filters" : [{
67+ "update_account_topic" : " solana.testnet.account_updates" ,
68+ "slot_status_topic" : " solana.testnet.slot_status" ,
69+ "transaction_topic" : " solana.testnet.transactions" ,
70+ "program_ignores" : [
71+ " Sysvar1111111111111111111111111111111111111" ,
72+ " Vote111111111111111111111111111111111111111"
73+ ],
74+ "publish_all_accounts" : false ,
75+ "wrap_messages" : false
76+ }]
7477}
7578```
7679
7780### Reference
7881
7982- ` libpath ` : Path to Kafka plugin
8083- ` kafka ` : [ ` librdkafka ` config options] ( https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md ) .
81- This plugin overrides the defaults as seen in the example config.
8284- ` shutdown_timeout_ms ` : Time the plugin is given to flush out all messages to Kafka upon exit request.
83- - ` update_account_topic ` : Topic name of account updates. Omit to disable.
84- - ` slot_status_topic ` : Topic name of slot status update. Omit to disable.
85- - ` publish_all_accounts ` : Publish all accounts on startup. Omit to disable.
86- - ` wrap_messages ` : Wrap all messages in a unified wrapper object. Omit to disable (see Message Wrapping below).
87- - ` program_ignores ` : Account addresses to ignore (see Filtering below).
85+ - ` prometheus ` : Optional port to provide metrics in Prometheus format.
86+ - ` filters ` : Vec of filters with next fields:
87+ - ` update_account_topic ` : Topic name of account updates. Omit to disable.
88+ - ` slot_status_topic ` : Topic name of slot status update. Omit to disable.
89+ - ` transaction_topic ` : Topic name of transaction update. Omit to disable.
90+ - ` program_ignores ` : Account addresses to ignore (see Filtering below).
91+ - ` program_filters ` : Solana program IDs to include.
92+ - ` account_filters ` : Solana accounts to include.
93+ - ` publish_all_accounts ` : Publish all accounts on startup. Omit to disable.
94+ - ` include_vote_transactions ` : Include Vote transactions.
95+ - ` include_failed_transactions ` : Include failed transactions.
96+ - ` wrap_messages ` : Wrap all messages in a unified wrapper object. Omit to disable (see Message Wrapping below).
8897
8998### Message Keys
9099
0 commit comments