@@ -59,32 +59,41 @@ Config is specified via the plugin's JSON config file.
59
59
"request.required.acks" : " 1" ,
60
60
"message.timeout.ms" : " 30000" ,
61
61
"compression.type" : " lz4" ,
62
- "partitioner" : " murmur2_random"
62
+ "partitioner" : " murmur2_random" ,
63
+ "statistics.interval.ms" : " 1000"
63
64
},
64
65
"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
+ }]
74
77
}
75
78
```
76
79
77
80
### Reference
78
81
79
82
- ` libpath ` : Path to Kafka plugin
80
83
- ` 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.
82
84
- ` 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).
88
97
89
98
### Message Keys
90
99
0 commit comments