Create topcis.json
{
"version": 1,
"topics": [
{ "topic": "my-sample-topic"
| #!/bin/bash | |
| # from https://github.com/cernceph/ceph-scripts/blob/master/tools/scrubbing/autorepair.sh | |
| for PG in $(ceph pg ls inconsistent -f json | jq -r .pg_stats[].pgid) | |
| do | |
| echo Checking inconsistent PG $PG | |
| if ceph pg ls repair | grep -wq ${PG} | |
| then | |
| echo PG $PG is already repairing, skipping | |
| continue |
| filter { | |
| if [type] == "cassandralog" { | |
| grok { | |
| break_on_match => true | |
| match => { | |
| "message" => [ | |
| "%{CASS_COMPACTION_LARGE_KEY}", | |
| "%{CASS_SLAB_POOL_CLEANER_1}", | |
| "%{CASS_SLAB_POOL_CLEANER_2}", |
| package main | |
| import ( | |
| "context" | |
| "flag" | |
| "fmt" | |
| "log" | |
| "net/http" | |
| "os" | |
| "os/signal" |