我试图找出消费者群体层面是否也存在任何抵消。消费者偏移量是在消费者组级别还是在 Kafka 中该消费者组内的单个消费者?
我们如何将过滤器应用于Observable以便我们可以根据某些条件获取数据?我的要求是我想从userObservable 中过滤掉状态为“已批准”的用户。
下面是我的http服务方法。
getUserList(){
return this.httpClient.get<UserModel[]>(environment.userListUrl);
}
Run Code Online (Sandbox Code Playgroud)
下面是用户模型
export class UserModel{
userName: string;
userStatus: string;
}
Run Code Online (Sandbox Code Playgroud)
这就是我想要做的,但不确定如何应用过滤器,以便我可以获取userStatus为“已批准”的用户
const userObservable$: Observable<UserModel[]>=this.userService.getUserList(this.cmpnyId);
observable$.pipe(filter(....<Need help here>));
Run Code Online (Sandbox Code Playgroud)