Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

bump gommap to 6edfc90 to support FreeBSD amd64 #173

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

bump gommap to 6edfc90 to support FreeBSD amd64 #173

wants to merge 1 commit into from

Conversation

dch
Copy link

@dch dch commented Feb 11, 2021

I'd like to add jocko to FreeBSD ports - with this patch, we already get amd64 support for mmap. I will see what's missing to add arm64 support as well, but that will take a bit longer to work through.

$ uname -a
FreeBSD 14.0-CURRENT main-n244674-a4f26914d4d5 GENERIC-NODEBUG  amd64

$ gmake
?   	github.com/travisjeffery/jocko/cmd/jocko	[no test files]
=== RUN   TestIndex
--- PASS: TestIndex (0.00s)
=== RUN   TestIndexScanner
--- PASS: TestIndexScanner (0.00s)
=== RUN   TestNewCommitLog
--- PASS: TestNewCommitLog (0.00s)
=== RUN   TestTruncate
--- PASS: TestTruncate (0.00s)
=== RUN   TestCleaner
--- PASS: TestCleaner (0.00s)
=== RUN   TestCompactCleaner
--- PASS: TestCompactCleaner (0.00s)
=== RUN   TestDeleteCleaner
--- PASS: TestDeleteCleaner (0.00s)
=== RUN   TestMessageSet
--- PASS: TestMessageSet (0.00s)
=== RUN   TestMessages
--- PASS: TestMessages (0.00s)
=== RUN   TestMessage
--- PASS: TestMessage (0.00s)
=== RUN   TestReader
=== RUN   TestReader/6
=== RUN   TestReader/60
=== RUN   TestReader/600
=== RUN   TestReader/6000
--- PASS: TestReader (0.00s)
    --- PASS: TestReader/6 (0.00s)
    --- PASS: TestReader/60 (0.00s)
    --- PASS: TestReader/600 (0.00s)
    --- PASS: TestReader/6000 (0.00s)
=== RUN   TestSegmentScanner
--- PASS: TestSegmentScanner (0.00s)
PASS
ok  	github.com/travisjeffery/jocko/commitlog	0.011s
=== RUN   TestNewBrokerLookup
--- PASS: TestNewBrokerLookup (0.00s)
=== RUN   TestBroker_Run
=== RUN   TestBroker_Run/api_versions
2021-02-11T12:58:35.975Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:1 Address:127.0.0.1:10002}]
2021-02-11T12:58:35.975Z [INFO]  raft: Node at 127.0.0.1:10002 [Leader] entering Leader state
2021/02/11 12:58:35.975651 serf/1: [INFO] serf: EventMemberJoin: TestBroker_Run/api_versions-node-1 127.0.0.1
2021/02/11 12:58:35.975759 broker_test: leader/1: cluster leadership acquired
2021/02/11 12:58:35.975835 broker_test: broker/1: adding LAN server: 1
2021/02/11 12:58:35.975898 broker_test: broker/1: raft data found, disabling bootstrap mode: index: 3, path: /tmp/jocko-test-server-1962560940/raft
2021/02/11 12:58:35.975916 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:35.975946 broker_test: leader/1: member joined, marking health alive: TestBroker_Run/api_versions-node-1
2021/02/11 12:58:35.976237 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.002462 broker_test: broker/1: request: ctx: correlation id: 1, api key: 0, client: , size: 0
2021/02/11 12:58:36.002517 broker_test: broker/1: run done
2021/02/11 12:58:36.002650 broker_test: broker/1: shutting down broker
2021/02/11 12:58:36.002667 serf/1: [WARN] serf: Shutdown without a Leave
=== RUN   TestBroker_Run/create_topic_ok
2021-02-11T12:58:36.003Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:1 Address:127.0.0.1:10006}]
2021-02-11T12:58:36.004Z [INFO]  raft: Node at 127.0.0.1:10006 [Leader] entering Leader state
2021/02/11 12:58:36.004368 serf/1: [INFO] serf: EventMemberJoin: TestBroker_Run/create_topic_ok-node-2 127.0.0.1
2021/02/11 12:58:36.004438 broker_test: leader/1: cluster leadership acquired
2021/02/11 12:58:36.004439 broker_test: broker/1: adding LAN server: 1
2021/02/11 12:58:36.004462 broker_test: broker/1: raft data found, disabling bootstrap mode: index: 2, path: /tmp/jocko-test-server-2946557211/raft
2021/02/11 12:58:36.004674 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.004707 broker_test: leader/1: member joined, marking health alive: TestBroker_Run/create_topic_ok-node-2
2021/02/11 12:58:36.004962 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.029736 broker_test: broker/1: request: ctx: correlation id: 1, api key: 0, client: , size: 0
2021/02/11 12:58:36.029788 broker_test: broker/1: run done
2021/02/11 12:58:36.029959 broker_test: broker/1: shutting down broker
2021/02/11 12:58:36.029974 serf/1: [WARN] serf: Shutdown without a Leave
=== RUN   TestBroker_Run/create_topic_invalid_replication_factor_error
2021-02-11T12:58:36.032Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:1 Address:127.0.0.1:10010}]
2021-02-11T12:58:36.032Z [INFO]  raft: Node at 127.0.0.1:10010 [Leader] entering Leader state
2021/02/11 12:58:36.032578 serf/1: [INFO] serf: EventMemberJoin: TestBroker_Run/create_topic_invalid_replication_factor_error-node-3 127.0.0.1
2021/02/11 12:58:36.032635 broker_test: leader/1: cluster leadership acquired
2021/02/11 12:58:36.032643 broker_test: broker/1: adding LAN server: 1
2021/02/11 12:58:36.032708 broker_test: broker/1: raft data found, disabling bootstrap mode: index: 2, path: /tmp/jocko-test-server-3266246590/raft
2021/02/11 12:58:36.032860 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.032883 broker_test: leader/1: member joined, marking health alive: TestBroker_Run/create_topic_invalid_replication_factor_error-node-3
2021/02/11 12:58:36.033096 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.057713 broker_test: broker/1: request: ctx: correlation id: 1, api key: 0, client: , size: 0
2021/02/11 12:58:36.057764 broker_test: broker/1: run done
2021/02/11 12:58:36.057905 broker_test: broker/1: shutting down broker
2021/02/11 12:58:36.057923 serf/1: [WARN] serf: Shutdown without a Leave
=== RUN   TestBroker_Run/delete_topic
2021-02-11T12:58:36.059Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:1 Address:127.0.0.1:10014}]
2021-02-11T12:58:36.059Z [INFO]  raft: Node at 127.0.0.1:10014 [Leader] entering Leader state
2021/02/11 12:58:36.059707 serf/1: [INFO] serf: EventMemberJoin: TestBroker_Run/delete_topic-node-4 127.0.0.1
2021/02/11 12:58:36.059762 broker_test: leader/1: cluster leadership acquired
2021/02/11 12:58:36.059763 broker_test: broker/1: adding LAN server: 1
2021/02/11 12:58:36.059785 broker_test: broker/1: raft data found, disabling bootstrap mode: index: 2, path: /tmp/jocko-test-server-4213653509/raft
2021/02/11 12:58:36.059921 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.059943 broker_test: leader/1: member joined, marking health alive: TestBroker_Run/delete_topic-node-4
2021/02/11 12:58:36.060146 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.085370 broker_test: broker/1: request: ctx: correlation id: 1, api key: 0, client: , size: 0
2021/02/11 12:58:36.085410 broker_test: broker/1: request: ctx: correlation id: 2, api key: 0, client: , size: 0
2021/02/11 12:58:36.085443 broker_test: broker/1: run done
2021/02/11 12:58:36.085563 broker_test: broker/1: shutting down broker
2021/02/11 12:58:36.085587 serf/1: [WARN] serf: Shutdown without a Leave
=== RUN   TestBroker_Run/offsets
2021-02-11T12:58:36.087Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:1 Address:127.0.0.1:10018}]
2021-02-11T12:58:36.087Z [INFO]  raft: Node at 127.0.0.1:10018 [Leader] entering Leader state
2021/02/11 12:58:36.087735 serf/1: [INFO] serf: EventMemberJoin: TestBroker_Run/offsets-node-5 127.0.0.1
2021/02/11 12:58:36.087787 broker_test: leader/1: cluster leadership acquired
2021/02/11 12:58:36.087793 broker_test: broker/1: adding LAN server: 1
2021/02/11 12:58:36.087820 broker_test: broker/1: raft data found, disabling bootstrap mode: index: 2, path: /tmp/jocko-test-server-5947463584/raft
2021/02/11 12:58:36.087946 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.087969 broker_test: leader/1: member joined, marking health alive: TestBroker_Run/offsets-node-5
2021/02/11 12:58:36.088172 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.112922 broker_test: broker/1: request: ctx: correlation id: 1, api key: 0, client: , size: 0
2021/02/11 12:58:36.113463 broker_test: broker/1: request: ctx: correlation id: 2, api key: 0, client: , size: 0
2021/02/11 12:58:36.113487 broker_test: broker/1: produce: &protocol.ProduceRequest{APIVersion:0, TransactionalID:(*string)(nil), Acks:0, Timeout:100000000, TopicData:[]*protocol.TopicData{(*protocol.TopicData)(0xc0001904e0)}}
2021/02/11 12:58:36.113499 broker_test: broker/1: produce to partition: 0: &{test-topic [0xc00000f860]}
2021/02/11 12:58:36.113576 broker_test: broker/1: request: ctx: correlation id: 3, api key: 0, client: , size: 0
2021/02/11 12:58:36.113605 broker_test: broker/1: request: ctx: correlation id: 4, api key: 0, client: , size: 0
2021/02/11 12:58:36.113628 broker_test: broker/1: run done
2021/02/11 12:58:36.113785 broker_test: broker/1: shutting down broker
2021/02/11 12:58:36.113802 serf/1: [WARN] serf: Shutdown without a Leave
=== RUN   TestBroker_Run/fetch
2021-02-11T12:58:36.115Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:1 Address:127.0.0.1:10022}]
2021-02-11T12:58:36.115Z [INFO]  raft: Node at 127.0.0.1:10022 [Leader] entering Leader state
2021/02/11 12:58:36.115475 serf/1: [INFO] serf: EventMemberJoin: TestBroker_Run/fetch-node-6 127.0.0.1
2021/02/11 12:58:36.115533 broker_test: leader/1: cluster leadership acquired
2021/02/11 12:58:36.115535 broker_test: broker/1: adding LAN server: 1
2021/02/11 12:58:36.115575 broker_test: broker/1: raft data found, disabling bootstrap mode: index: 2, path: /tmp/jocko-test-server-6039209599/raft
2021/02/11 12:58:36.115731 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.115774 broker_test: leader/1: member joined, marking health alive: TestBroker_Run/fetch-node-6
2021/02/11 12:58:36.115987 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.140719 broker_test: broker/1: request: ctx: correlation id: 1, api key: 0, client: , size: 0
2021/02/11 12:58:36.141226 broker_test: broker/1: request: ctx: correlation id: 2, api key: 0, client: , size: 0
2021/02/11 12:58:36.141246 broker_test: broker/1: produce: &protocol.ProduceRequest{APIVersion:0, TransactionalID:(*string)(nil), Acks:0, Timeout:100000000, TopicData:[]*protocol.TopicData{(*protocol.TopicData)(0xc0001907e0)}}
2021/02/11 12:58:36.141253 broker_test: broker/1: produce to partition: 0: &{test-topic [0xc00000f960]}
2021/02/11 12:58:36.141329 broker_test: broker/1: request: ctx: correlation id: 3, api key: 0, client: , size: 0
2021/02/11 12:58:36.141401 broker_test: broker/1: run done
2021/02/11 12:58:36.142078 broker_test: broker/1: shutting down broker
2021/02/11 12:58:36.142100 serf/1: [WARN] serf: Shutdown without a Leave
=== RUN   TestBroker_Run/metadata
2021-02-11T12:58:36.143Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:1 Address:127.0.0.1:10026}]
2021-02-11T12:58:36.143Z [INFO]  raft: Node at 127.0.0.1:10026 [Leader] entering Leader state
2021/02/11 12:58:36.143552 serf/1: [INFO] serf: EventMemberJoin: TestBroker_Run/metadata-node-7 127.0.0.1
2021/02/11 12:58:36.143605 broker_test: leader/1: cluster leadership acquired
2021/02/11 12:58:36.143607 broker_test: broker/1: adding LAN server: 1
2021/02/11 12:58:36.143636 broker_test: broker/1: raft data found, disabling bootstrap mode: index: 2, path: /tmp/jocko-test-server-7717650898/raft
2021/02/11 12:58:36.143757 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.143792 broker_test: leader/1: member joined, marking health alive: TestBroker_Run/metadata-node-7
2021/02/11 12:58:36.143985 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.168698 broker_test: broker/1: request: ctx: correlation id: 1, api key: 0, client: , size: 0
2021/02/11 12:58:36.169167 broker_test: broker/1: request: ctx: correlation id: 2, api key: 0, client: , size: 0
2021/02/11 12:58:36.169184 broker_test: broker/1: produce: &protocol.ProduceRequest{APIVersion:0, TransactionalID:(*string)(nil), Acks:0, Timeout:100000000, TopicData:[]*protocol.TopicData{(*protocol.TopicData)(0xc000190a20)}}
2021/02/11 12:58:36.169191 broker_test: broker/1: produce to partition: 0: &{test-topic [0xc00000fa80]}
2021/02/11 12:58:36.169265 broker_test: broker/1: request: ctx: correlation id: 3, api key: 0, client: , size: 0
2021/02/11 12:58:36.169333 broker_test: broker/1: run done
2021/02/11 12:58:36.169514 broker_test: broker/1: shutting down broker
2021/02/11 12:58:36.169531 serf/1: [WARN] serf: Shutdown without a Leave
=== RUN   TestBroker_Run/produce_topic/partition_doesn't_exist_error
2021-02-11T12:58:36.170Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:1 Address:127.0.0.1:10030}]
2021-02-11T12:58:36.170Z [INFO]  raft: Node at 127.0.0.1:10030 [Leader] entering Leader state
2021/02/11 12:58:36.171629 serf/1: [INFO] serf: EventMemberJoin: TestBroker_Run/produce_topic/partition_doesn't_exist_error-node-8 127.0.0.1
2021/02/11 12:58:36.171695 broker_test: broker/1: adding LAN server: 1
2021/02/11 12:58:36.171708 broker_test: leader/1: cluster leadership acquired
2021/02/11 12:58:36.171712 broker_test: broker/1: raft data found, disabling bootstrap mode: index: 2, path: /tmp/jocko-test-server-8714297609/raft
2021/02/11 12:58:36.171828 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.171864 broker_test: leader/1: member joined, marking health alive: TestBroker_Run/produce_topic/partition_doesn't_exist_error-node-8
2021/02/11 12:58:36.172057 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.196770 broker_test: broker/1: request: ctx: correlation id: 2, api key: 0, client: , size: 0
2021/02/11 12:58:36.196796 broker_test: broker/1: produce: &protocol.ProduceRequest{APIVersion:0, TransactionalID:(*string)(nil), Acks:0, Timeout:100000000, TopicData:[]*protocol.TopicData{(*protocol.TopicData)(0xc000190bd0)}}
2021/02/11 12:58:36.196805 broker_test: broker/1: produce to partition: 0: &{another-topic [0xc00000fba0]}
2021/02/11 12:58:36.196838 broker_test: broker/1: produce to partition error: unknown topic
2021/02/11 12:58:36.196889 broker_test: broker/1: run done
2021/02/11 12:58:36.197004 broker_test: broker/1: shutting down broker
2021/02/11 12:58:36.197023 serf/1: [WARN] serf: Shutdown without a Leave
=== RUN   TestBroker_Run/find_coordinator
2021-02-11T12:58:36.198Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:1 Address:127.0.0.1:10034}]
2021-02-11T12:58:36.198Z [INFO]  raft: Node at 127.0.0.1:10034 [Leader] entering Leader state
2021/02/11 12:58:36.198644 serf/1: [INFO] serf: EventMemberJoin: TestBroker_Run/find_coordinator-node-9 127.0.0.1
2021/02/11 12:58:36.198708 broker_test: broker/1: adding LAN server: 1
2021/02/11 12:58:36.198746 broker_test: broker/1: raft data found, disabling bootstrap mode: index: 2, path: /tmp/jocko-test-server-9243442388/raft
2021/02/11 12:58:36.198780 broker_test: leader/1: cluster leadership acquired
2021/02/11 12:58:36.198852 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.198888 broker_test: leader/1: member joined, marking health alive: TestBroker_Run/find_coordinator-node-9
2021/02/11 12:58:36.199090 broker_test: leader/1: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.223912 broker_test: broker/1: request: ctx: correlation id: 1, api key: 0, client: , size: 0
2021/02/11 12:58:36.224412 broker_test: broker/1: request: ctx: correlation id: 3, api key: 0, client: , size: 0
2021/02/11 12:58:36.231678 broker_test: broker/1: run done
2021/02/11 12:58:36.231852 broker_test: broker/1: shutting down broker
2021/02/11 12:58:36.231873 serf/1: [WARN] serf: Shutdown without a Leave
--- PASS: TestBroker_Run (0.26s)
    --- PASS: TestBroker_Run/api_versions (0.03s)
    --- PASS: TestBroker_Run/create_topic_ok (0.03s)
    --- PASS: TestBroker_Run/create_topic_invalid_replication_factor_error (0.03s)
    --- PASS: TestBroker_Run/delete_topic (0.03s)
    --- PASS: TestBroker_Run/offsets (0.03s)
    --- PASS: TestBroker_Run/fetch (0.03s)
    --- PASS: TestBroker_Run/metadata (0.03s)
    --- PASS: TestBroker_Run/produce_topic/partition_doesn't_exist_error (0.03s)
    --- PASS: TestBroker_Run/find_coordinator (0.03s)
=== RUN   TestBroker_Run_JoinSyncGroup
    broker_test.go:569: 
--- SKIP: TestBroker_Run_JoinSyncGroup (0.00s)
=== RUN   TestBroker_Shutdown
=== RUN   TestBroker_Shutdown/shutdown_ok
2021-02-11T12:58:36.233Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:10 Address:127.0.0.1:10038}]
2021-02-11T12:58:36.233Z [INFO]  raft: Node at 127.0.0.1:10038 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:36.233913 serf/10: [INFO] serf: EventMemberJoin: TestBroker_Shutdown/shutdown_ok-node-10 127.0.0.1
2021/02/11 12:58:36.233968 broker_test: server/10: run handler
2021/02/11 12:58:36.233974 broker_test: broker/10: shutting down broker
2021/02/11 12:58:36.233982 serf/10: [WARN] serf: Shutdown without a Leave
2021/02/11 12:58:36.234005 broker_test: broker/10: adding LAN server: 10
--- PASS: TestBroker_Shutdown (0.00s)
    --- PASS: TestBroker_Shutdown/shutdown_ok (0.00s)
=== RUN   TestBroker_JoinLAN
2021-02-11T12:58:36.235Z [INFO]  raft: Initial configuration (index=0): []
2021/02/11 12:58:36.235566 serf/11: [INFO] serf: EventMemberJoin: TestBroker_JoinLAN-node-11 127.0.0.1
2021-02-11T12:58:36.236Z [INFO]  raft: Node at 127.0.0.1:10042 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:36.236285 broker_test: broker/11: adding LAN server: 11
2021-02-11T12:58:36.236Z [INFO]  raft: Initial configuration (index=0): []
2021-02-11T12:58:36.236Z [INFO]  raft: Node at 127.0.0.1:10046 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:36.237309 serf/12: [INFO] serf: EventMemberJoin: TestBroker_JoinLAN-node-12 127.0.0.1
2021/02/11 12:58:36.237388 broker_test: broker/12: adding LAN server: 12
2021/02/11 12:58:36.237468 memberlist/12: [DEBUG] memberlist: Initiating push/pull sync with: 127.0.0.1:10043
2021/02/11 12:58:36.237491 memberlist/11: [DEBUG] memberlist: Stream connection from=127.0.0.1:22171
2021/02/11 12:58:36.237990 serf/11: [INFO] serf: EventMemberJoin: TestBroker_JoinLAN-node-12 127.0.0.1
2021/02/11 12:58:36.238066 broker_test: broker/11: adding LAN server: 12
2021/02/11 12:58:36.238115 serf/12: [INFO] serf: EventMemberJoin: TestBroker_JoinLAN-node-11 127.0.0.1
2021/02/11 12:58:36.238146 broker_test: broker/12: adding LAN server: 11
2021/02/11 12:58:36.238222 broker_test: broker/12: shutting down broker
2021/02/11 12:58:36.238234 serf/12: [WARN] serf: Shutdown without a Leave
2021/02/11 12:58:36.238468 broker_test: broker/11: shutting down broker
2021/02/11 12:58:36.238485 serf/11: [WARN] serf: Shutdown without a Leave
--- PASS: TestBroker_JoinLAN (0.00s)
=== RUN   TestBroker_RegisterMember
2021-02-11T12:58:36.239Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:13 Address:127.0.0.1:10050}]
2021-02-11T12:58:36.239Z [INFO]  raft: Node at 127.0.0.1:10050 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:36.239914 serf/13: [INFO] serf: EventMemberJoin: TestBroker_RegisterMember-node-13 127.0.0.1
2021/02/11 12:58:36.239970 broker_test: broker/13: adding LAN server: 13
2021/02/11 12:58:36.239988 broker_test: broker/13: raft data found, disabling bootstrap mode: index: 1, path: /tmp/jocko-test-server-13386614088/raft
2021-02-11T12:58:36.240Z [INFO]  raft: Initial configuration (index=0): []
2021-02-11T12:58:36.240Z [INFO]  raft: Node at 127.0.0.1:10054 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:36.241086 serf/14: [INFO] serf: EventMemberJoin: TestBroker_RegisterMember-node-14 127.0.0.1
2021/02/11 12:58:36.241172 broker_test: broker/14: adding LAN server: 14
2021/02/11 12:58:36.241193 broker_test: broker/14: maybe bootstrap: need more brokers: got: 1: expect: 3
2021/02/11 12:58:36.241229 memberlist/13: [DEBUG] memberlist: Initiating push/pull sync with: 127.0.0.1:10055
2021/02/11 12:58:36.241256 memberlist/14: [DEBUG] memberlist: Stream connection from=127.0.0.1:22172
2021/02/11 12:58:36.241924 serf/14: [INFO] serf: EventMemberJoin: TestBroker_RegisterMember-node-13 127.0.0.1
2021/02/11 12:58:36.242087 broker_test: broker/14: adding LAN server: 13
2021/02/11 12:58:36.242183 broker_test: broker/14; member TestBroker_RegisterMember-node-13 has bootstrap mode. expect disabled
2021/02/11 12:58:36.242189 serf/13: [INFO] serf: EventMemberJoin: TestBroker_RegisterMember-node-14 127.0.0.1
2021/02/11 12:58:36.242408 broker_test: broker/13: adding LAN server: 14
2021/02/11 12:58:36.340469 serf/14: [DEBUG] serf: messageJoinType: TestBroker_RegisterMember-node-13
2021/02/11 12:58:36.340604 serf/14: [DEBUG] serf: messageJoinType: TestBroker_RegisterMember-node-13
2021/02/11 12:58:36.341461 serf/13: [DEBUG] serf: messageJoinType: TestBroker_RegisterMember-node-13
2021/02/11 12:58:36.341502 serf/13: [DEBUG] serf: messageJoinType: TestBroker_RegisterMember-node-13
2021/02/11 12:58:36.490092 broker_test: broker/13: state:
	members:
		- 0:
			name: TestBroker_RegisterMember-node-13
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_RegisterMember-node-14
			addr: 127.0.0.1
			status: alive
	nodes:
	topics:
2021/02/11 12:58:36.491327 broker_test: broker/14: state:
	members:
		- 0:
			name: TestBroker_RegisterMember-node-14
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_RegisterMember-node-13
			addr: 127.0.0.1
			status: alive
	nodes:
	topics:
2021-02-11T12:58:36.498Z [WARN]  raft: no known peers, aborting election
2021-02-11T12:58:36.638Z [WARN]  raft: Heartbeat timeout from "" reached, starting election
2021-02-11T12:58:36.638Z [INFO]  raft: Node at 127.0.0.1:10050 [Candidate] entering Candidate state in term 2
2021-02-11T12:58:36.639Z [DEBUG] raft: Votes needed: 1
2021-02-11T12:58:36.639Z [DEBUG] raft: Vote granted from 13 in term 2. Tally: 1
2021-02-11T12:58:36.639Z [INFO]  raft: Election won. Tally: 1
2021-02-11T12:58:36.639Z [INFO]  raft: Node at 127.0.0.1:10050 [Leader] entering Leader state
2021/02/11 12:58:36.639176 broker_test: leader/13: cluster leadership acquired
2021/02/11 12:58:36.639282 broker_test: leader/13: join cluster: add voter: 14
2021-02-11T12:58:36.639Z [INFO]  raft: Updating configuration with AddStaging (14, 127.0.0.1:10054) to [{Suffrage:Voter ID:13 Address:127.0.0.1:10050} {Suffrage:Voter ID:14 Address:127.0.0.1:10054}]
2021-02-11T12:58:36.639Z [INFO]  raft: Added peer 14, starting replication
2021/02/11 12:58:36.639441 broker_test: leader/13: member joined, marking health alive: TestBroker_RegisterMember-node-14
2021/02/11 12:58:36 [DEBUG] raft-net: 127.0.0.1:10054 accepted connection from: 127.0.0.1:22182
2021-02-11T12:58:36.639Z [WARN]  raft: Failed to get previous log: 4 log not found (last: 0)
2021-02-11T12:58:36.639Z [WARN]  raft: AppendEntries to {Voter 14 127.0.0.1:10054} rejected, sending older logs (next: 1)
2021-02-11T12:58:36.640Z [INFO]  raft: pipelining replication to peer {Voter 14 127.0.0.1:10054}
2021/02/11 12:58:36.640478 broker_test: leader/13: skipping self join since cluster is too small: servers: 2
2021/02/11 12:58:36.640512 broker_test: leader/13: member joined, marking health alive: TestBroker_RegisterMember-node-13
2021/02/11 12:58:36.646671 broker_test: broker/14: shutting down broker
2021/02/11 12:58:36.646693 serf/14: [WARN] serf: Shutdown without a Leave
2021/02/11 12:58:36.647044 broker_test: broker/13: shutting down broker
2021/02/11 12:58:36.647066 serf/13: [WARN] serf: Shutdown without a Leave
2021-02-11T12:58:36.647Z [INFO]  raft: aborting pipeline replication to peer {Voter 14 127.0.0.1:10054}
--- PASS: TestBroker_RegisterMember (0.41s)
=== RUN   TestBroker_FailedMember
2021-02-11T12:58:36.649Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:15 Address:127.0.0.1:10058}]
2021-02-11T12:58:36.649Z [INFO]  raft: Node at 127.0.0.1:10058 [Leader] entering Leader state
2021/02/11 12:58:36.649731 serf/15: [INFO] serf: EventMemberJoin: TestBroker_FailedMember-node-15 127.0.0.1
2021/02/11 12:58:36.649798 broker_test: leader/15: cluster leadership acquired
2021/02/11 12:58:36.649817 broker_test: broker/15: adding LAN server: 15
2021/02/11 12:58:36.649840 broker_test: broker/15: raft data found, disabling bootstrap mode: index: 2, path: /tmp/jocko-test-server-15115152314/raft
2021/02/11 12:58:36.649895 broker_test: leader/15: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:36.649933 broker_test: leader/15: member joined, marking health alive: TestBroker_FailedMember-node-15
2021/02/11 12:58:36.650128 broker_test: leader/15: skipping self join since cluster is too small: servers: 1
2021-02-11T12:58:36.650Z [INFO]  raft: Initial configuration (index=0): []
2021-02-11T12:58:36.650Z [INFO]  raft: Node at 127.0.0.1:10062 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:36.650988 serf/16: [INFO] serf: EventMemberJoin: TestBroker_FailedMember-node-16 127.0.0.1
2021/02/11 12:58:36.651034 broker_test: broker/16: adding LAN server: 16
2021/02/11 12:58:36.651126 memberlist/15: [DEBUG] memberlist: Initiating push/pull sync with: 127.0.0.1:10063
2021/02/11 12:58:36.651163 memberlist/16: [DEBUG] memberlist: Stream connection from=127.0.0.1:22183
2021/02/11 12:58:36.651557 serf/16: [INFO] serf: EventMemberJoin: TestBroker_FailedMember-node-15 127.0.0.1
2021/02/11 12:58:36.651606 broker_test: broker/16: adding LAN server: 15
2021/02/11 12:58:36.651717 serf/15: [INFO] serf: EventMemberJoin: TestBroker_FailedMember-node-16 127.0.0.1
2021/02/11 12:58:36.651758 broker_test: broker/15: adding LAN server: 16
2021/02/11 12:58:36.651775 broker_test: broker/16: shutting down broker
2021/02/11 12:58:36.651787 serf/16: [WARN] serf: Shutdown without a Leave
2021-02-11T12:58:36.651Z [INFO]  raft: Updating configuration with AddNonvoter (16, 127.0.0.1:10062) to [{Suffrage:Voter ID:15 Address:127.0.0.1:10058} {Suffrage:Nonvoter ID:16 Address:127.0.0.1:10062}]
2021-02-11T12:58:36.651Z [INFO]  raft: Added peer 16, starting replication
2021/02/11 12:58:36.651919 broker_test: leader/15: member joined, marking health alive: TestBroker_FailedMember-node-16
2021/02/11 12:58:36.677177 broker_test: broker/15: shutting down broker
2021/02/11 12:58:36.677196 serf/15: [WARN] serf: Shutdown without a Leave
2021-02-11T12:58:46.652Z [ERROR] raft: Failed to AppendEntries to {Nonvoter 16 127.0.0.1:10062}: dial tcp 127.0.0.1:10062: i/o timeout
2021-02-11T12:58:46.673Z [ERROR] raft: Failed to heartbeat to 127.0.0.1:10062: dial tcp 127.0.0.1:10062: i/o timeout
--- PASS: TestBroker_FailedMember (10.03s)
=== RUN   TestBroker_LeftMember
2021-02-11T12:58:46.676Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:17 Address:127.0.0.1:10066}]
2021-02-11T12:58:46.676Z [INFO]  raft: Node at 127.0.0.1:10066 [Leader] entering Leader state
2021/02/11 12:58:46.676858 serf/17: [INFO] serf: EventMemberJoin: TestBroker_LeftMember-node-17 127.0.0.1
2021/02/11 12:58:46.676932 broker_test: leader/17: cluster leadership acquired
2021/02/11 12:58:46.676975 broker_test: broker/17: adding LAN server: 17
2021/02/11 12:58:46.677002 broker_test: broker/17: raft data found, disabling bootstrap mode: index: 2, path: /tmp/jocko-test-server-17924346108/raft
2021/02/11 12:58:46.677107 broker_test: leader/17: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:46.677143 broker_test: leader/17: member joined, marking health alive: TestBroker_LeftMember-node-17
2021/02/11 12:58:46.677416 broker_test: leader/17: skipping self join since cluster is too small: servers: 1
2021-02-11T12:58:46.678Z [INFO]  raft: Initial configuration (index=0): []
2021-02-11T12:58:46.678Z [INFO]  raft: Node at 127.0.0.1:10070 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:46.678576 serf/18: [INFO] serf: EventMemberJoin: TestBroker_LeftMember-node-18 127.0.0.1
2021/02/11 12:58:46.678638 broker_test: broker/18: adding LAN server: 18
2021/02/11 12:58:46.678729 memberlist/17: [DEBUG] memberlist: Initiating push/pull sync with: 127.0.0.1:10071
2021/02/11 12:58:46.678766 memberlist/18: [DEBUG] memberlist: Stream connection from=127.0.0.1:22272
2021/02/11 12:58:46.679156 serf/18: [INFO] serf: EventMemberJoin: TestBroker_LeftMember-node-17 127.0.0.1
2021/02/11 12:58:46.679201 broker_test: broker/18: adding LAN server: 17
2021/02/11 12:58:46.679247 serf/17: [INFO] serf: EventMemberJoin: TestBroker_LeftMember-node-18 127.0.0.1
2021/02/11 12:58:46.679291 broker_test: broker/17: adding LAN server: 18
2021-02-11T12:58:46.679Z [INFO]  raft: Updating configuration with AddNonvoter (18, 127.0.0.1:10070) to [{Suffrage:Voter ID:17 Address:127.0.0.1:10066} {Suffrage:Nonvoter ID:18 Address:127.0.0.1:10070}]
2021-02-11T12:58:46.679Z [INFO]  raft: Added peer 18, starting replication
2021/02/11 12:58:46.679462 broker_test: leader/17: member joined, marking health alive: TestBroker_LeftMember-node-18
2021/02/11 12:58:46 [DEBUG] raft-net: 127.0.0.1:10070 accepted connection from: 127.0.0.1:22273
2021-02-11T12:58:46.679Z [WARN]  raft: Failed to get previous log: 5 log not found (last: 0)
2021-02-11T12:58:46.679Z [WARN]  raft: AppendEntries to {Nonvoter 18 127.0.0.1:10070} rejected, sending older logs (next: 1)
2021-02-11T12:58:46.680Z [INFO]  raft: pipelining replication to peer {Nonvoter 18 127.0.0.1:10070}
2021/02/11 12:58:46.704442 broker_test: broker/18: starting leave
2021/02/11 12:58:46 [DEBUG] raft-net: 127.0.0.1:10070 accepted connection from: 127.0.0.1:22274
2021/02/11 12:58:46.778088 serf/18: [DEBUG] serf: messageJoinType: TestBroker_LeftMember-node-17
2021/02/11 12:58:46.778564 serf/18: [DEBUG] serf: messageJoinType: TestBroker_LeftMember-node-17
2021/02/11 12:58:46.778684 serf/17: [DEBUG] serf: messageJoinType: TestBroker_LeftMember-node-17
2021/02/11 12:58:46.778718 serf/18: [INFO] serf: EventMemberLeave: TestBroker_LeftMember-node-18 127.0.0.1
2021/02/11 12:58:46.778721 serf/17: [DEBUG] serf: messageLeaveType: TestBroker_LeftMember-node-18
2021/02/11 12:58:46.778755 broker_test: broker/18: removing LAN server: TestBroker_LeftMember-node-18
2021/02/11 12:58:46.779045 serf/17: [DEBUG] serf: messageJoinType: TestBroker_LeftMember-node-17
2021/02/11 12:58:46.779092 serf/18: [DEBUG] serf: messageLeaveType: TestBroker_LeftMember-node-18
2021/02/11 12:58:46.779119 serf/17: [DEBUG] serf: messageLeaveType: TestBroker_LeftMember-node-18
2021/02/11 12:58:46.877073 serf/18: [DEBUG] serf: messageLeaveType: TestBroker_LeftMember-node-18
2021/02/11 12:58:46.878873 serf/17: [INFO] serf: EventMemberLeave: TestBroker_LeftMember-node-18 127.0.0.1
2021/02/11 12:58:46.878902 broker_test: broker/17: removing LAN server: TestBroker_LeftMember-node-18
2021/02/11 12:58:46.878931 broker_test: leader/17: removing server by id: 18
2021-02-11T12:58:46.878Z [INFO]  raft: Updating configuration with RemoveServer (18, ) to [{Suffrage:Voter ID:17 Address:127.0.0.1:10066}]
2021-02-11T12:58:46.879Z [INFO]  raft: Removed peer 18, stopping replication after 7
2021/02/11 12:58:46.879231 broker_test: leader/17: member is deregistering: reason: left; node: 18
2021-02-11T12:58:46.879Z [INFO]  raft: aborting pipeline replication to peer {Nonvoter 18 127.0.0.1:10070}
2021/02/11 12:58:46 [ERR] raft-net: Failed to flush response: write tcp 127.0.0.1:10070->127.0.0.1:22273: write: broken pipe
2021/02/11 12:58:46.927226 broker_test: broker/17: state:
	members:
		- 0:
			name: TestBroker_LeftMember-node-17
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftMember-node-18
			addr: 127.0.0.1
			status: left
	nodes:
		- 0:
			id: 17
			status: passing
	topics:
2021/02/11 12:58:46.928842 broker_test: broker/18: state:
	members:
		- 0:
			name: TestBroker_LeftMember-node-17
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftMember-node-18
			addr: 127.0.0.1
			status: left
	nodes:
		- 0:
			id: 17
			status: passing
		- 1:
			id: 18
			status: passing
	topics:
2021/02/11 12:58:46.977115 broker_test: leader/17: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:47.177017 broker_test: broker/17: state:
	members:
		- 0:
			name: TestBroker_LeftMember-node-17
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftMember-node-18
			addr: 127.0.0.1
			status: left
	nodes:
		- 0:
			id: 17
			status: passing
	topics:
2021/02/11 12:58:47.178704 broker_test: broker/18: state:
	members:
		- 0:
			name: TestBroker_LeftMember-node-18
			addr: 127.0.0.1
			status: left
		- 1:
			name: TestBroker_LeftMember-node-17
			addr: 127.0.0.1
			status: alive
	nodes:
		- 0:
			id: 17
			status: passing
		- 1:
			id: 18
			status: passing
	topics:
2021/02/11 12:58:47.278541 broker_test: leader/17: skipping self join since cluster is too small: servers: 1
2021-02-11T12:58:47.349Z [WARN]  raft: not part of stable configuration, aborting election
2021/02/11 12:58:47.427102 broker_test: broker/17: state:
	members:
		- 0:
			name: TestBroker_LeftMember-node-17
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftMember-node-18
			addr: 127.0.0.1
			status: left
	nodes:
		- 0:
			id: 17
			status: passing
	topics:
2021/02/11 12:58:47.428784 broker_test: broker/18: state:
	members:
		- 0:
			name: TestBroker_LeftMember-node-18
			addr: 127.0.0.1
			status: left
		- 1:
			name: TestBroker_LeftMember-node-17
			addr: 127.0.0.1
			status: alive
	nodes:
		- 0:
			id: 17
			status: passing
		- 1:
			id: 18
			status: passing
	topics:
2021/02/11 12:58:47.578682 broker_test: leader/17: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:47.677040 broker_test: broker/17: state:
	members:
		- 0:
			name: TestBroker_LeftMember-node-17
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftMember-node-18
			addr: 127.0.0.1
			status: left
	nodes:
		- 0:
			id: 17
			status: passing
	topics:
2021/02/11 12:58:47.678681 broker_test: broker/18: state:
	members:
		- 0:
			name: TestBroker_LeftMember-node-18
			addr: 127.0.0.1
			status: left
		- 1:
			name: TestBroker_LeftMember-node-17
			addr: 127.0.0.1
			status: alive
	nodes:
		- 0:
			id: 17
			status: passing
		- 1:
			id: 18
			status: passing
	topics:
2021/02/11 12:58:47.878796 broker_test: leader/17: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:47.927054 broker_test: broker/17: state:
	members:
		- 0:
			name: TestBroker_LeftMember-node-17
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftMember-node-18
			addr: 127.0.0.1
			status: left
	nodes:
		- 0:
			id: 17
			status: passing
	topics:
2021/02/11 12:58:47.928782 broker_test: broker/18: state:
	members:
		- 0:
			name: TestBroker_LeftMember-node-18
			addr: 127.0.0.1
			status: left
		- 1:
			name: TestBroker_LeftMember-node-17
			addr: 127.0.0.1
			status: alive
	nodes:
		- 0:
			id: 17
			status: passing
		- 1:
			id: 18
			status: passing
	topics:
2021/02/11 12:58:48.030607 broker_test: broker/18: shutting down broker
2021/02/11 12:58:48.031079 broker_test: broker/17: shutting down broker
2021/02/11 12:58:48.031144 serf/17: [WARN] serf: Shutdown without a Leave
--- PASS: TestBroker_LeftMember (1.36s)
=== RUN   TestBroker_ReapLeader
2021-02-11T12:58:48.033Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:19 Address:127.0.0.1:10074}]
2021-02-11T12:58:48.033Z [INFO]  raft: Node at 127.0.0.1:10074 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:48.034025 serf/19: [INFO] serf: EventMemberJoin: TestBroker_ReapLeader-node-19 127.0.0.1
2021/02/11 12:58:48.034396 broker_test: broker/19: adding LAN server: 19
2021-02-11T12:58:48.035Z [INFO]  raft: Initial configuration (index=0): []
2021/02/11 12:58:48.036356 serf/20: [INFO] serf: EventMemberJoin: TestBroker_ReapLeader-node-20 127.0.0.1
2021-02-11T12:58:48.036Z [INFO]  raft: Node at 127.0.0.1:10078 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:48.036560 broker_test: broker/20: adding LAN server: 20
2021-02-11T12:58:48.037Z [INFO]  raft: Initial configuration (index=0): []
2021-02-11T12:58:48.037Z [INFO]  raft: Node at 127.0.0.1:10082 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:48.038149 serf/21: [INFO] serf: EventMemberJoin: TestBroker_ReapLeader-node-21 127.0.0.1
2021/02/11 12:58:48.038285 broker_test: broker/21: adding LAN server: 21
2021/02/11 12:58:48.038352 memberlist/20: [DEBUG] memberlist: Initiating push/pull sync with: 127.0.0.1:10075
2021/02/11 12:58:48.038515 memberlist/19: [DEBUG] memberlist: Stream connection from=127.0.0.1:22283
2021/02/11 12:58:48.038986 serf/19: [INFO] serf: EventMemberJoin: TestBroker_ReapLeader-node-20 127.0.0.1
2021/02/11 12:58:48.039166 serf/20: [INFO] serf: EventMemberJoin: TestBroker_ReapLeader-node-19 127.0.0.1
2021/02/11 12:58:48.039178 broker_test: broker/19: adding LAN server: 20
2021/02/11 12:58:48.039291 broker_test: broker/20: adding LAN server: 19
2021/02/11 12:58:48.039462 memberlist/21: [DEBUG] memberlist: Initiating push/pull sync with: 127.0.0.1:10075
2021/02/11 12:58:48.039645 memberlist/19: [DEBUG] memberlist: Stream connection from=127.0.0.1:22284
2021/02/11 12:58:48.041132 serf/19: [INFO] serf: EventMemberJoin: TestBroker_ReapLeader-node-21 127.0.0.1
2021/02/11 12:58:48.041320 broker_test: broker/19: adding LAN server: 21
2021/02/11 12:58:48.041673 serf/21: [INFO] serf: EventMemberJoin: TestBroker_ReapLeader-node-20 127.0.0.1
2021/02/11 12:58:48.041842 serf/21: [INFO] serf: EventMemberJoin: TestBroker_ReapLeader-node-19 127.0.0.1
2021/02/11 12:58:48.041862 broker_test: broker/21: adding LAN server: 20
2021/02/11 12:58:48.042174 broker_test: broker/21: adding LAN server: 19
2021/02/11 12:58:48.135683 serf/20: [INFO] serf: EventMemberJoin: TestBroker_ReapLeader-node-21 127.0.0.1
2021/02/11 12:58:48.135892 broker_test: broker/20: adding LAN server: 21
2021/02/11 12:58:48.136122 serf/19: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-20
2021/02/11 12:58:48.136877 serf/21: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-20
2021/02/11 12:58:48.137086 serf/20: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-20
2021/02/11 12:58:48.138664 serf/20: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-21
2021/02/11 12:58:48.138692 serf/20: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-20
2021/02/11 12:58:48.138940 serf/21: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-20
2021/02/11 12:58:48.138972 serf/19: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-21
2021/02/11 12:58:48.138991 serf/19: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-20
2021/02/11 12:58:48.234410 serf/20: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-21
2021/02/11 12:58:48.234594 serf/21: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-21
2021/02/11 12:58:48.236661 serf/19: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-21
2021/02/11 12:58:48.236810 serf/21: [DEBUG] serf: messageJoinType: TestBroker_ReapLeader-node-21
2021-02-11T12:58:48.238Z [WARN]  raft: Heartbeat timeout from "" reached, starting election
2021-02-11T12:58:48.238Z [INFO]  raft: Node at 127.0.0.1:10074 [Candidate] entering Candidate state in term 2
2021-02-11T12:58:48.238Z [DEBUG] raft: Votes needed: 1
2021-02-11T12:58:48.238Z [DEBUG] raft: Vote granted from 19 in term 2. Tally: 1
2021-02-11T12:58:48.238Z [INFO]  raft: Election won. Tally: 1
2021-02-11T12:58:48.238Z [INFO]  raft: Node at 127.0.0.1:10074 [Leader] entering Leader state
2021/02/11 12:58:48.238867 broker_test: leader/19: cluster leadership acquired
2021/02/11 12:58:48.238989 broker_test: leader/19: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:48.239052 broker_test: leader/19: member joined, marking health alive: TestBroker_ReapLeader-node-19
2021/02/11 12:58:48.239385 broker_test: leader/19: join cluster: add voter: 20
2021-02-11T12:58:48.239Z [INFO]  raft: Updating configuration with AddStaging (20, 127.0.0.1:10078) to [{Suffrage:Voter ID:19 Address:127.0.0.1:10074} {Suffrage:Voter ID:20 Address:127.0.0.1:10078}]
2021-02-11T12:58:48.239Z [INFO]  raft: Added peer 20, starting replication
2021/02/11 12:58:48.239561 broker_test: leader/19: member joined, marking health alive: TestBroker_ReapLeader-node-20
2021/02/11 12:58:48 [DEBUG] raft-net: 127.0.0.1:10078 accepted connection from: 127.0.0.1:22285
2021-02-11T12:58:48.239Z [WARN]  raft: Failed to get previous log: 5 log not found (last: 0)
2021-02-11T12:58:48.240Z [WARN]  raft: AppendEntries to {Voter 20 127.0.0.1:10078} rejected, sending older logs (next: 1)
2021-02-11T12:58:48.240Z [INFO]  raft: pipelining replication to peer {Voter 20 127.0.0.1:10078}
2021/02/11 12:58:48.240952 broker_test: leader/19: join cluster: add voter: 21
2021-02-11T12:58:48.241Z [INFO]  raft: Updating configuration with AddStaging (21, 127.0.0.1:10082) to [{Suffrage:Voter ID:19 Address:127.0.0.1:10074} {Suffrage:Voter ID:20 Address:127.0.0.1:10078} {Suffrage:Voter ID:21 Address:127.0.0.1:10082}]
2021-02-11T12:58:48.241Z [INFO]  raft: Added peer 21, starting replication
2021/02/11 12:58:48 [DEBUG] raft-net: 127.0.0.1:10082 accepted connection from: 127.0.0.1:22286
2021-02-11T12:58:48.241Z [WARN]  raft: Failed to get previous log: 7 log not found (last: 0)
2021/02/11 12:58:48.241646 broker_test: leader/19: member joined, marking health alive: TestBroker_ReapLeader-node-21
2021-02-11T12:58:48.241Z [WARN]  raft: AppendEntries to {Voter 21 127.0.0.1:10082} rejected, sending older logs (next: 1)
2021-02-11T12:58:48.242Z [INFO]  raft: pipelining replication to peer {Voter 21 127.0.0.1:10082}
2021/02/11 12:58:48.247242 broker_test: leader/19: removing server by id: 21
2021-02-11T12:58:48.247Z [INFO]  raft: Updating configuration with RemoveServer (21, ) to [{Suffrage:Voter ID:19 Address:127.0.0.1:10074} {Suffrage:Voter ID:20 Address:127.0.0.1:10078}]
2021-02-11T12:58:48.247Z [INFO]  raft: Removed peer 21, stopping replication after 9
2021-02-11T12:58:48.247Z [INFO]  raft: aborting pipeline replication to peer {Voter 21 127.0.0.1:10082}
2021/02/11 12:58:48.247822 broker_test: leader/19: member is deregistering: reason: reaped; node: 21
2021/02/11 12:58:48.248474 broker_test: broker/21: shutting down broker
2021/02/11 12:58:48.248500 serf/21: [WARN] serf: Shutdown without a Leave
2021/02/11 12:58:48.248919 broker_test: broker/20: shutting down broker
2021/02/11 12:58:48.248950 serf/20: [WARN] serf: Shutdown without a Leave
2021/02/11 12:58:48.249283 broker_test: broker/19: shutting down broker
2021/02/11 12:58:48.249343 serf/19: [WARN] serf: Shutdown without a Leave
2021-02-11T12:58:48.249Z [INFO]  raft: aborting pipeline replication to peer {Voter 20 127.0.0.1:10078}
--- PASS: TestBroker_ReapLeader (0.22s)
=== RUN   TestBroker_ReapMember
2021-02-11T12:58:48.251Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:22 Address:127.0.0.1:10086}]
2021-02-11T12:58:48.251Z [INFO]  raft: Node at 127.0.0.1:10086 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:48.252253 serf/22: [INFO] serf: EventMemberJoin: TestBroker_ReapMember-node-22 127.0.0.1
2021/02/11 12:58:48.252425 broker_test: broker/22: adding LAN server: 22
2021-02-11T12:58:48.253Z [INFO]  raft: Initial configuration (index=0): []
2021-02-11T12:58:48.253Z [INFO]  raft: Node at 127.0.0.1:10090 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:48.254108 serf/23: [INFO] serf: EventMemberJoin: TestBroker_ReapMember-node-23 127.0.0.1
2021/02/11 12:58:48.254233 broker_test: broker/23: adding LAN server: 23
2021/02/11 12:58:48.254322 memberlist/23: [DEBUG] memberlist: Initiating push/pull sync with: 127.0.0.1:10087
2021/02/11 12:58:48.254345 memberlist/22: [DEBUG] memberlist: Stream connection from=127.0.0.1:22287
2021/02/11 12:58:48.254869 serf/22: [INFO] serf: EventMemberJoin: TestBroker_ReapMember-node-23 127.0.0.1
2021/02/11 12:58:48.254944 broker_test: broker/22: adding LAN server: 23
2021/02/11 12:58:48.255170 serf/23: [INFO] serf: EventMemberJoin: TestBroker_ReapMember-node-22 127.0.0.1
2021/02/11 12:58:48.255223 broker_test: broker/23: adding LAN server: 22
2021/02/11 12:58:48.353174 serf/22: [DEBUG] serf: messageJoinType: TestBroker_ReapMember-node-23
2021/02/11 12:58:48.354419 serf/22: [DEBUG] serf: messageJoinType: TestBroker_ReapMember-node-23
2021/02/11 12:58:48.354549 serf/23: [DEBUG] serf: messageJoinType: TestBroker_ReapMember-node-23
2021/02/11 12:58:48.452518 serf/23: [DEBUG] serf: messageJoinType: TestBroker_ReapMember-node-23
2021-02-11T12:58:48.459Z [WARN]  raft: Heartbeat timeout from "" reached, starting election
2021-02-11T12:58:48.459Z [INFO]  raft: Node at 127.0.0.1:10086 [Candidate] entering Candidate state in term 2
2021-02-11T12:58:48.459Z [DEBUG] raft: Votes needed: 1
2021-02-11T12:58:48.459Z [DEBUG] raft: Vote granted from 22 in term 2. Tally: 1
2021-02-11T12:58:48.459Z [INFO]  raft: Election won. Tally: 1
2021-02-11T12:58:48.459Z [INFO]  raft: Node at 127.0.0.1:10086 [Leader] entering Leader state
2021/02/11 12:58:48.459596 broker_test: leader/22: cluster leadership acquired
2021/02/11 12:58:48.459703 broker_test: leader/22: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:48.459756 broker_test: leader/22: member joined, marking health alive: TestBroker_ReapMember-node-22
2021/02/11 12:58:48.460055 broker_test: leader/22: join cluster: add voter: 23
2021-02-11T12:58:48.460Z [INFO]  raft: Updating configuration with AddStaging (23, 127.0.0.1:10090) to [{Suffrage:Voter ID:22 Address:127.0.0.1:10086} {Suffrage:Voter ID:23 Address:127.0.0.1:10090}]
2021-02-11T12:58:48.460Z [INFO]  raft: Added peer 23, starting replication
2021/02/11 12:58:48.460228 broker_test: leader/22: member joined, marking health alive: TestBroker_ReapMember-node-23
2021/02/11 12:58:48 [DEBUG] raft-net: 127.0.0.1:10090 accepted connection from: 127.0.0.1:22288
2021-02-11T12:58:48.460Z [WARN]  raft: Failed to get previous log: 5 log not found (last: 0)
2021-02-11T12:58:48.460Z [WARN]  raft: AppendEntries to {Voter 23 127.0.0.1:10090} rejected, sending older logs (next: 1)
2021-02-11T12:58:48.461Z [INFO]  raft: pipelining replication to peer {Voter 23 127.0.0.1:10090}
2021/02/11 12:58:48.482137 broker_test: leader/22: removing server by id: 23
2021-02-11T12:58:48.482Z [INFO]  raft: Updating configuration with RemoveServer (23, ) to [{Suffrage:Voter ID:22 Address:127.0.0.1:10086}]
2021-02-11T12:58:48.482Z [INFO]  raft: Removed peer 23, stopping replication after 7
2021/02/11 12:58:48.482405 broker_test: leader/22: member is deregistering: reason: reaped; node: 23
2021-02-11T12:58:48.482Z [INFO]  raft: aborting pipeline replication to peer {Voter 23 127.0.0.1:10090}
2021/02/11 12:58:48.482634 broker_test: broker/23: shutting down broker
2021/02/11 12:58:48.482664 serf/23: [WARN] serf: Shutdown without a Leave
2021/02/11 12:58:48 [ERR] raft-net: Failed to flush response: write tcp 127.0.0.1:10090->127.0.0.1:22288: write: broken pipe
2021/02/11 12:58:48.483153 broker_test: broker/22: shutting down broker
2021/02/11 12:58:48.483179 serf/22: [WARN] serf: Shutdown without a Leave
--- PASS: TestBroker_ReapMember (0.23s)
=== RUN   TestBroker_LeftLeader
2021-02-11T12:58:48.485Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:24 Address:127.0.0.1:10094}]
2021-02-11T12:58:48.485Z [INFO]  raft: Node at 127.0.0.1:10094 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:48.485659 serf/24: [INFO] serf: EventMemberJoin: TestBroker_LeftLeader-node-24 127.0.0.1
2021/02/11 12:58:48.485784 broker_test: broker/24: adding LAN server: 24
2021/02/11 12:58:48.485845 broker_test: broker/24: raft data found, disabling bootstrap mode: index: 1, path: /tmp/jocko-test-server-24293516697/raft
2021-02-11T12:58:48.486Z [INFO]  raft: Initial configuration (index=0): []
2021-02-11T12:58:48.486Z [INFO]  raft: Node at 127.0.0.1:10098 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:48.487334 serf/25: [INFO] serf: EventMemberJoin: TestBroker_LeftLeader-node-25 127.0.0.1
2021/02/11 12:58:48.487438 broker_test: broker/25: adding LAN server: 25
2021/02/11 12:58:48.487462 broker_test: broker/25: maybe bootstrap: need more brokers: got: 1: expect: 3
2021-02-11T12:58:48.488Z [INFO]  raft: Initial configuration (index=0): []
2021-02-11T12:58:48.488Z [INFO]  raft: Node at 127.0.0.1:10102 [Follower] entering Follower state (Leader: "")
2021/02/11 12:58:48.488986 serf/26: [INFO] serf: EventMemberJoin: TestBroker_LeftLeader-node-26 127.0.0.1
2021/02/11 12:58:48.489062 broker_test: broker/26: adding LAN server: 26
2021/02/11 12:58:48.489078 broker_test: broker/26: maybe bootstrap: need more brokers: got: 1: expect: 3
2021/02/11 12:58:48.489168 memberlist/24: [DEBUG] memberlist: Initiating push/pull sync with: 127.0.0.1:10099
2021/02/11 12:58:48.489210 memberlist/25: [DEBUG] memberlist: Stream connection from=127.0.0.1:22289
2021/02/11 12:58:48.489649 serf/25: [INFO] serf: EventMemberJoin: TestBroker_LeftLeader-node-24 127.0.0.1
2021/02/11 12:58:48.489718 broker_test: broker/25: adding LAN server: 24
2021/02/11 12:58:48.489746 broker_test: broker/25; member TestBroker_LeftLeader-node-24 has bootstrap mode. expect disabled
2021/02/11 12:58:48.489861 serf/24: [INFO] serf: EventMemberJoin: TestBroker_LeftLeader-node-25 127.0.0.1
2021/02/11 12:58:48.489917 broker_test: broker/24: adding LAN server: 25
2021/02/11 12:58:48.490118 memberlist/24: [DEBUG] memberlist: Initiating push/pull sync with: 127.0.0.1:10103
2021/02/11 12:58:48.490161 memberlist/26: [DEBUG] memberlist: Stream connection from=127.0.0.1:22290
2021/02/11 12:58:48.491058 serf/26: [INFO] serf: EventMemberJoin: TestBroker_LeftLeader-node-25 127.0.0.1
2021/02/11 12:58:48.491166 serf/26: [INFO] serf: EventMemberJoin: TestBroker_LeftLeader-node-24 127.0.0.1
2021/02/11 12:58:48.491343 broker_test: broker/26: adding LAN server: 25
2021/02/11 12:58:48.491412 serf/24: [INFO] serf: EventMemberJoin: TestBroker_LeftLeader-node-26 127.0.0.1
2021/02/11 12:58:48.491434 broker_test: broker/26; member TestBroker_LeftLeader-node-24 has bootstrap mode. expect disabled
2021/02/11 12:58:48.491561 broker_test: broker/26: adding LAN server: 24
2021/02/11 12:58:48.491606 broker_test: broker/26; member TestBroker_LeftLeader-node-24 has bootstrap mode. expect disabled
2021/02/11 12:58:48.491687 broker_test: broker/24: adding LAN server: 26
2021/02/11 12:58:48.586551 serf/25: [INFO] serf: EventMemberJoin: TestBroker_LeftLeader-node-26 127.0.0.1
2021/02/11 12:58:48.586597 serf/25: [DEBUG] serf: messageJoinType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.586620 serf/25: [DEBUG] serf: messageJoinType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.586650 broker_test: broker/25: adding LAN server: 26
2021/02/11 12:58:48.586704 broker_test: broker/25; member TestBroker_LeftLeader-node-24 has bootstrap mode. expect disabled
2021/02/11 12:58:48.586828 serf/26: [DEBUG] serf: messageJoinType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.586851 serf/26: [DEBUG] serf: messageJoinType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.587807 serf/24: [DEBUG] serf: messageJoinType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.587827 serf/24: [DEBUG] serf: messageJoinType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.587988 serf/24: [DEBUG] serf: messageJoinType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.588011 serf/24: [DEBUG] serf: messageJoinType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.589492 serf/25: [DEBUG] serf: messageJoinType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.589556 serf/24: [DEBUG] serf: messageJoinType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.735927 broker_test: broker/24: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
	nodes:
	topics:
2021/02/11 12:58:48.737564 broker_test: broker/25: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
	nodes:
	topics:
2021/02/11 12:58:48.739225 broker_test: broker/26: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: alive
	nodes:
	topics:
2021-02-11T12:58:48.800Z [WARN]  raft: no known peers, aborting election
2021-02-11T12:58:48.841Z [WARN]  raft: Heartbeat timeout from "" reached, starting election
2021-02-11T12:58:48.841Z [INFO]  raft: Node at 127.0.0.1:10094 [Candidate] entering Candidate state in term 2
2021-02-11T12:58:48.841Z [DEBUG] raft: Votes needed: 1
2021-02-11T12:58:48.841Z [DEBUG] raft: Vote granted from 24 in term 2. Tally: 1
2021-02-11T12:58:48.841Z [INFO]  raft: Election won. Tally: 1
2021-02-11T12:58:48.841Z [INFO]  raft: Node at 127.0.0.1:10094 [Leader] entering Leader state
2021/02/11 12:58:48.841667 broker_test: leader/24: cluster leadership acquired
2021/02/11 12:58:48.841831 broker_test: leader/24: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:48.841903 broker_test: leader/24: member joined, marking health alive: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.842205 broker_test: leader/24: join cluster: add voter: 25
2021-02-11T12:58:48.842Z [INFO]  raft: Updating configuration with AddStaging (25, 127.0.0.1:10098) to [{Suffrage:Voter ID:24 Address:127.0.0.1:10094} {Suffrage:Voter ID:25 Address:127.0.0.1:10098}]
2021-02-11T12:58:48.842Z [INFO]  raft: Added peer 25, starting replication
2021/02/11 12:58:48.842381 broker_test: leader/24: member joined, marking health alive: TestBroker_LeftLeader-node-25
2021/02/11 12:58:48 [DEBUG] raft-net: 127.0.0.1:10098 accepted connection from: 127.0.0.1:22300
2021-02-11T12:58:48.842Z [WARN]  raft: Failed to get previous log: 5 log not found (last: 0)
2021-02-11T12:58:48.842Z [WARN]  raft: AppendEntries to {Voter 25 127.0.0.1:10098} rejected, sending older logs (next: 1)
2021-02-11T12:58:48.843Z [INFO]  raft: pipelining replication to peer {Voter 25 127.0.0.1:10098}
2021/02/11 12:58:48.843565 broker_test: leader/24: join cluster: add voter: 26
2021-02-11T12:58:48.843Z [INFO]  raft: Updating configuration with AddStaging (26, 127.0.0.1:10102) to [{Suffrage:Voter ID:24 Address:127.0.0.1:10094} {Suffrage:Voter ID:25 Address:127.0.0.1:10098} {Suffrage:Voter ID:26 Address:127.0.0.1:10102}]
2021-02-11T12:58:48.843Z [INFO]  raft: Added peer 26, starting replication
2021/02/11 12:58:48 [DEBUG] raft-net: 127.0.0.1:10102 accepted connection from: 127.0.0.1:22301
2021-02-11T12:58:48.844Z [WARN]  raft: Failed to get previous log: 7 log not found (last: 0)
2021-02-11T12:58:48.844Z [WARN]  raft: AppendEntries to {Voter 26 127.0.0.1:10102} rejected, sending older logs (next: 1)
2021/02/11 12:58:48.844236 broker_test: leader/24: member joined, marking health alive: TestBroker_LeftLeader-node-26
2021/02/11 12:58:48.851151 broker_test: broker/24: starting leave
2021-02-11T12:58:48.851Z [INFO]  raft: Updating configuration with RemoveServer (24, ) to [{Suffrage:Voter ID:25 Address:127.0.0.1:10098} {Suffrage:Voter ID:26 Address:127.0.0.1:10102}]
2021-02-11T12:58:48.851Z [INFO]  raft: pipelining replication to peer {Voter 26 127.0.0.1:10102}
2021-02-11T12:58:48.852Z [INFO]  raft: Removed ourself, shutting down
2021/02/11 12:58:48.852260 broker_test: leader/24: shutting down leader loop
2021-02-11T12:58:48.852Z [INFO]  raft: aborting pipeline replication to peer {Voter 25 127.0.0.1:10098}
2021-02-11T12:58:48.852Z [INFO]  raft: aborting pipeline replication to peer {Voter 26 127.0.0.1:10102}
2021/02/11 12:58:48.852273 broker_test: leader/24: cluster leadership lost
2021/02/11 12:58:48.885970 serf/26: [DEBUG] serf: messageLeaveType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.885986 serf/24: [INFO] serf: EventMemberLeave: TestBroker_LeftLeader-node-24 127.0.0.1
2021/02/11 12:58:48.886022 broker_test: broker/24: removing LAN server: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.886202 serf/25: [DEBUG] serf: messageLeaveType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.887550 serf/24: [DEBUG] serf: messageLeaveType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.887764 serf/24: [DEBUG] serf: messageLeaveType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.887842 serf/25: [INFO] serf: EventMemberLeave: TestBroker_LeftLeader-node-24 127.0.0.1
2021/02/11 12:58:48.887873 broker_test: broker/25: removing LAN server: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.889278 serf/24: [DEBUG] serf: messageLeaveType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.889408 serf/24: [DEBUG] serf: messageLeaveType: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.889476 serf/26: [INFO] serf: EventMemberLeave: TestBroker_LeftLeader-node-24 127.0.0.1
2021/02/11 12:58:48.889501 broker_test: broker/26: removing LAN server: TestBroker_LeftLeader-node-24
2021/02/11 12:58:48.985843 broker_test: broker/24: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
		- 1:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
	nodes:
		- 0:
			id: 24
			status: passing
		- 1:
			id: 25
			status: passing
		- 2:
			id: 26
			status: passing
	topics:
2021/02/11 12:58:48.987458 broker_test: broker/25: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
		- 1:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
	nodes:
		- 0:
			id: 24
			status: passing
		- 1:
			id: 25
			status: passing
		- 2:
			id: 26
			status: passing
	topics:
2021/02/11 12:58:48.989141 broker_test: broker/26: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
	nodes:
		- 0:
			id: 24
			status: passing
		- 1:
			id: 25
			status: passing
		- 2:
			id: 26
			status: passing
	topics:
2021-02-11T12:58:49.181Z [WARN]  raft: Heartbeat timeout from "127.0.0.1:10094" reached, starting election
2021-02-11T12:58:49.181Z [INFO]  raft: Node at 127.0.0.1:10098 [Candidate] entering Candidate state in term 3
2021-02-11T12:58:49.181Z [DEBUG] raft: Votes needed: 2
2021-02-11T12:58:49.181Z [DEBUG] raft: Vote granted from 25 in term 3. Tally: 1
2021/02/11 12:58:49 [DEBUG] raft-net: 127.0.0.1:10102 accepted connection from: 127.0.0.1:22302
2021-02-11T12:58:49.181Z [WARN]  raft: Rejecting vote request from 127.0.0.1:10098 since we have a leader: 127.0.0.1:10094
2021-02-11T12:58:49.218Z [WARN]  raft: Heartbeat timeout from "127.0.0.1:10094" reached, starting election
2021-02-11T12:58:49.218Z [INFO]  raft: Node at 127.0.0.1:10102 [Candidate] entering Candidate state in term 3
2021-02-11T12:58:49.218Z [DEBUG] raft: Votes needed: 2
2021-02-11T12:58:49.218Z [DEBUG] raft: Vote granted from 26 in term 3. Tally: 1
2021/02/11 12:58:49 [DEBUG] raft-net: 127.0.0.1:10098 accepted connection from: 127.0.0.1:22303
2021-02-11T12:58:49.218Z [INFO]  raft: Duplicate RequestVote for same term: 3
2021/02/11 12:58:49.235858 broker_test: broker/24: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
		- 1:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
	nodes:
		- 0:
			id: 24
			status: passing
		- 1:
			id: 25
			status: passing
		- 2:
			id: 26
			status: passing
	topics:
2021/02/11 12:58:49.237512 broker_test: broker/25: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
		- 2:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
	nodes:
		- 0:
			id: 24
			status: passing
		- 1:
			id: 25
			status: passing
		- 2:
			id: 26
			status: passing
	topics:
2021/02/11 12:58:49.239146 broker_test: broker/26: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
	nodes:
		- 0:
			id: 24
			status: passing
		- 1:
			id: 25
			status: passing
		- 2:
			id: 26
			status: passing
	topics:
2021-02-11T12:58:49.403Z [WARN]  raft: Election timeout reached, restarting election
2021-02-11T12:58:49.403Z [INFO]  raft: Node at 127.0.0.1:10098 [Candidate] entering Candidate state in term 4
2021-02-11T12:58:49.403Z [DEBUG] raft: Votes needed: 2
2021-02-11T12:58:49.403Z [DEBUG] raft: Vote granted from 25 in term 4. Tally: 1
2021-02-11T12:58:49.403Z [DEBUG] raft: lost leadership because received a requestvote with newer term
2021-02-11T12:58:49.403Z [INFO]  raft: Node at 127.0.0.1:10102 [Follower] entering Follower state (Leader: "")
2021-02-11T12:58:49.403Z [DEBUG] raft: Vote granted from 26 in term 4. Tally: 2
2021-02-11T12:58:49.403Z [INFO]  raft: Election won. Tally: 2
2021-02-11T12:58:49.403Z [INFO]  raft: Node at 127.0.0.1:10098 [Leader] entering Leader state
2021-02-11T12:58:49.403Z [INFO]  raft: Added peer 26, starting replication
2021/02/11 12:58:49.403863 broker_test: leader/25: cluster leadership acquired
2021-02-11T12:58:49.404Z [INFO]  raft: pipelining replication to peer {Voter 26 127.0.0.1:10102}
2021/02/11 12:58:49.404401 broker_test: leader/25: member is deregistering: reason: left; node: 24
2021/02/11 12:58:49.404885 broker_test: leader/25: skipping self join since cluster is too small: servers: 2
2021/02/11 12:58:49 [DEBUG] raft-net: 127.0.0.1:10102 accepted connection from: 127.0.0.1:22304
2021/02/11 12:58:49.485822 broker_test: broker/24: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
		- 1:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
	nodes:
		- 0:
			id: 24
			status: passing
		- 1:
			id: 25
			status: passing
		- 2:
			id: 26
			status: passing
	topics:
2021/02/11 12:58:49.487478 broker_test: broker/25: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
		- 2:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
	nodes:
		- 0:
			id: 25
			status: passing
		- 1:
			id: 26
			status: passing
	topics:
2021/02/11 12:58:49.489119 broker_test: broker/26: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
	nodes:
		- 0:
			id: 24
			status: passing
		- 1:
			id: 25
			status: passing
		- 2:
			id: 26
			status: passing
	topics:
2021/02/11 12:58:49.704396 broker_test: leader/25: skipping self join since cluster is too small: servers: 2
2021/02/11 12:58:49.735886 broker_test: broker/24: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
		- 1:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
	nodes:
		- 0:
			id: 24
			status: passing
		- 1:
			id: 25
			status: passing
		- 2:
			id: 26
			status: passing
	topics:
2021/02/11 12:58:49.737495 broker_test: broker/25: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
	nodes:
		- 0:
			id: 25
			status: passing
		- 1:
			id: 26
			status: passing
	topics:
2021/02/11 12:58:49.739200 broker_test: broker/26: state:
	members:
		- 0:
			name: TestBroker_LeftLeader-node-26
			addr: 127.0.0.1
			status: alive
		- 1:
			name: TestBroker_LeftLeader-node-25
			addr: 127.0.0.1
			status: alive
		- 2:
			name: TestBroker_LeftLeader-node-24
			addr: 127.0.0.1
			status: left
	nodes:
		- 0:
			id: 25
			status: passing
		- 1:
			id: 26
			status: passing
	topics:
2021/02/11 12:58:49.890382 broker_test: broker/24: shutting down broker
2021/02/11 12:58:49.890615 broker_test: broker/26: shutting down broker
2021/02/11 12:58:49.890639 serf/26: [WARN] serf: Shutdown without a Leave
2021/02/11 12:58:49.890936 broker_test: broker/25: shutting down broker
2021/02/11 12:58:49.890958 serf/25: [WARN] serf: Shutdown without a Leave
2021-02-11T12:58:49.891Z [INFO]  raft: aborting pipeline replication to peer {Voter 26 127.0.0.1:10102}
2021/02/11 12:58:49.891326 broker_test: broker/24: shutting down broker
--- PASS: TestBroker_LeftLeader (1.41s)
=== RUN   TestConn
2021-02-11T12:58:49.892Z [INFO]  raft: Initial configuration (index=1): [{Suffrage:Voter ID:27 Address:127.0.0.1:10106}]
2021-02-11T12:58:49.892Z [INFO]  raft: Node at 127.0.0.1:10106 [Leader] entering Leader state
2021/02/11 12:58:49.893226 serf/27: [INFO] serf: EventMemberJoin: TestConn-node-27 127.0.0.1
2021/02/11 12:58:49.893290 broker_test: server/27: run handler
=== RUN   TestConn/close_immediately
2021/02/11 12:58:49.893303 broker_test: leader/27: cluster leadership acquired
2021/02/11 12:58:49.893312 broker_test: broker/27: adding LAN server: 27
2021/02/11 12:58:49.893334 broker_test: broker/27: raft data found, disabling bootstrap mode: index: 2, path: /tmp/jocko-test-server-27020760310/raft
2021/02/11 12:58:49.893463 broker_test: leader/27: skipping self join since cluster is too small: servers: 1
=== RUN   TestConn/create_topice
2021/02/11 12:58:49.893505 broker_test: leader/27: member joined, marking health alive: TestConn-node-27
2021/02/11 12:58:49.893709 broker_test: server/27: handle request: ctx: correlation id: 1, api key: 19, client: , size: 44
2021/02/11 12:58:49.893739 broker_test: broker/27: request: ctx: correlation id: 1, api key: 19, client: , size: 44
2021/02/11 12:58:49.893778 broker_test: leader/27: skipping self join since cluster is too small: servers: 1
2021/02/11 12:58:49.893789 broker_test: server/27: handle response: ctx: correlation id: 1, api key: 19, client: , size: 44
=== RUN   TestConn/leader_and_isr
2021/02/11 12:58:49.894100 broker_test: server/27: handle request: ctx: correlation id: 1, api key: 4, client: , size: 74
2021/02/11 12:58:49.894116 broker_test: broker/27: request: ctx: correlation id: 1, api key: 4, client: , size: 74
2021/02/11 12:58:49.894142 broker_test: server/27: handle response: ctx: correlation id: 1, api key: 4, client: , size: 74
=== RUN   TestConn/fetch
2021/02/11 12:58:49.894440 broker_test: server/27: handle request: ctx: correlation id: 1, api key: 1, client: , size: 58
2021/02/11 12:58:49.894464 broker_test: broker/27: request: ctx: correlation id: 1, api key: 1, client: , size: 58
2021/02/11 12:58:49.894494 broker_test: server/27: handle response: ctx: correlation id: 1, api key: 1, client: , size: 58
=== RUN   TestConn/alter_configs
    conn_test.go:187: 
2021/02/11 12:58:49.894750 broker_test: broker/27: shutting down broker
2021/02/11 12:58:49.894766 serf/27: [WARN] serf: Shutdown without a Leave
2021/02/11 12:58:49.894906 broker_test: server/27: listener accept error: accept tcp 127.0.0.1:10105: use of closed network connection
--- PASS: TestConn (0.00s)
    --- PASS: TestConn/close_immediately (0.00s)
    --- PASS: TestConn/create_topice (0.00s)
    --- PASS: TestConn/leader_and_isr (0.00s)
    --- PASS: TestConn/fetch (0.00s)
    --- SKIP: TestConn/alter_configs (0.00s)
=== RUN   TestNewReplicaLookup
--- PASS: TestNewReplicaLookup (0.00s)
=== RUN   TestBroker_Replicate
--- PASS: TestBroker_Replicate (0.01s)
=== RUN   TestProduceConsume
    server_test.go:30: 
--- SKIP: TestProduceConsume (0.00s)
=== RUN   TestConsumerGroup
    server_test.go:176: 
--- SKIP: TestConsumerGroup (0.00s)
PASS
ok  	github.com/travisjeffery/jocko/jocko	13.944s
?   	github.com/travisjeffery/jocko/jocko/config	[no test files]
=== RUN   TestRegisterNode
--- PASS: TestRegisterNode (0.00s)
=== RUN   TestRegisterTopic
--- PASS: TestRegisterTopic (0.00s)
=== RUN   TestRegisterPartition
--- PASS: TestRegisterPartition (0.00s)
=== RUN   TestRegisterGroup
--- PASS: TestRegisterGroup (0.00s)
=== RUN   TestStore_maxIndex
--- PASS: TestStore_maxIndex (0.00s)
=== RUN   TestStore_Abandon
--- PASS: TestStore_Abandon (0.00s)
=== RUN   TestStore_DeleteNode
--- PASS: TestStore_DeleteNode (0.00s)
=== RUN   TestStore_RegisterTopic
--- PASS: TestStore_RegisterTopic (0.00s)
=== RUN   TestStore_RegisterPartition
--- PASS: TestStore_RegisterPartition (0.00s)
=== RUN   TestStore_RegisterGroup
--- PASS: TestStore_RegisterGroup (0.00s)
PASS
ok  	github.com/travisjeffery/jocko/jocko/fsm	(cached)
=== RUN   TestIsBroker
=== RUN   TestIsBroker/minumum_config
--- PASS: TestIsBroker (0.00s)
    --- PASS: TestIsBroker/minumum_config (0.00s)
PASS
ok  	github.com/travisjeffery/jocko/jocko/metadata	(cached)
?   	github.com/travisjeffery/jocko/jocko/state	[no test files]
=== RUN   TestEncodeDecode
=== RUN   TestEncodeDecode/partition
=== RUN   TestEncodeDecode/group
--- PASS: TestEncodeDecode (0.00s)
    --- PASS: TestEncodeDecode/partition (0.00s)
    --- PASS: TestEncodeDecode/group (0.00s)
PASS
ok  	github.com/travisjeffery/jocko/jocko/structs	(cached)
?   	github.com/travisjeffery/jocko/jocko/util	[no test files]
?   	github.com/travisjeffery/jocko/log	[no test files]
?   	github.com/travisjeffery/jocko/mock	[no test files]
=== RUN   TestAlterConfigsRequest
--- PASS: TestAlterConfigsRequest (0.00s)
=== RUN   TestAlterConfigsResponse
--- PASS: TestAlterConfigsResponse (0.00s)
=== RUN   TestCreateTopicRequests
--- PASS: TestCreateTopicRequests (0.00s)
=== RUN   TestCreateTopicResponse
--- PASS: TestCreateTopicResponse (0.00s)
=== RUN   TestDescribeConfigsRequest
--- PASS: TestDescribeConfigsRequest (0.00s)
=== RUN   TestDescribeConfigsResponse
--- PASS: TestDescribeConfigsResponse (0.00s)
=== RUN   TestFetchRequest
--- PASS: TestFetchRequest (0.00s)
=== RUN   TestFetchResponse
--- PASS: TestFetchResponse (0.00s)
=== RUN   TestFindCoordinatorRequest
--- PASS: TestFindCoordinatorRequest (0.00s)
=== RUN   TestFindCoordinatorResponse
--- PASS: TestFindCoordinatorResponse (0.00s)
=== RUN   TestHeartbeatRequest
--- PASS: TestHeartbeatRequest (0.00s)
=== RUN   TestLeaderAndISRRequest
--- PASS: TestLeaderAndISRRequest (0.00s)
=== RUN   TestLeaderAndISRResponse
--- PASS: TestLeaderAndISRResponse (0.00s)
PASS
ok  	github.com/travisjeffery/jocko/protocol	(cached)
?   	github.com/travisjeffery/jocko/testutil	[no test files]

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.

None yet
1 participant
@dch