Hi, All
I am reading the messages from producer and print the "time" and
"userhostaddress", but I am getting such warning once in a while:
184.146.220.124
1403070062
24.79.224.172
1403070063
71.199.4.138
2644780 [Thread-16-spout0] WARN storm.artemis.kafka.KafkaUtils - No data
found in Kafka Partition partition_2
1403070064
172.4.221.83
2647191 [Thread-16-spout0] INFO storm.artemis.kafka.trident.ZkBrokerReader
- brokers need refreshing because 60000ms have expired
2647195 [Thread-16-spout0] INFO storm.artemis.kafka.DynamicBrokersReader -
Read partition info from zookeeper:
GlobalPartitionInformation{partitionMap={0=10.100.70.128:9092, 1=
10.100.70.128:9092, 2=10.100.70.128:9092, 3=10.100.70.128:9092, 4=
10.100.70.128:9092}}
2648569 [Thread-8-$spoutcoord-spout0] INFO
storm.artemis.kafka.trident.ZkBrokerReader - brokers need refreshing
because 60000ms have expired
2648573 [Thread-8-$spoutcoord-spout0] INFO
storm.artemis.kafka.DynamicBrokersReader - Read partition info from
zookeeper: GlobalPartitionInformation{partitionMap={0=10.100.70.128:9092, 1=
10.100.70.128:9092, 2=10.100.70.128:9092, 3=10.100.70.128:9092, 4=
10.100.70.128:9092}}
1403070068
24.85.157.225
1403070070
24.114.78.75
1403070070
76.219.198.176
1403070071
142.166.228.205
1403070071
76.66.155.166
1403070071
172.56.10.86
1403070071
.
.
.
It says brokers need refreshing because 60000ms have expired, I didn't see
any 60000ms being configured anywhere, I wonder what this issue is. In
addition, I started 3 kafka brokers, and 5 partitions for the "topictest",
topic: topictest partition: 0 leader: 1 replicas: 1,3,2
isr: 1,2,3
topic: topictest partition: 1 leader: 1 replicas: 2,1,3
isr: 1,2,3
topic: topictest partition: 2 leader: 1 replicas: 3,2,1
isr: 1,2,3
topic: topictest partition: 3 leader: 1 replicas: 1,2,3
isr: 1,2,3
topic: topictest partition: 4 leader: 1 replicas: 2,3,1
isr: 1,2,3
What I don't understand is that I couldn't see BrokerReader for the brokers
9093 and 9094. And also what that means "No data found in Kafka Partition
partition_2".
thanks
Alec
