可以说我有多个设备.每个设备都有不同类型的传感器.现在我想将每个传感器的每个设备的数据发送到kafka.但我对卡夫卡主题感到困惑.用于处理此实时数据
每个设备都有kafka主题并且该设备的所有传感器都会将数据发送到特定的kafka主题,或者我应该创建一个主题并让所有设备将数据发送到该主题.
如果我选择第一个案例,我们将在每个设备上创建主题,
Device1(传感器A,B,C) - > topic1
Device2(传感器A,B,C) - > topic2
案例2:在哪里,将数据发送到一个主题
Device1(传感器A,B,C),Device2(传感器A,B,C)...... DeviceN .... - >主题
这不会成为数据的瓶颈.因为它将表现为来自某个传感器的队列数据将在队列中落后并且不会被实时处理.
这个模型会扩展吗?
编辑
让我们说每个设备都与用户(多对一)相关联.所以我想根据设备处理数据.因此,我想处理数据的方式是,每个设备及其传感器数据将在经过一些处理后发送给用户.
说我做了以下
DEVICE1
- >传感器A - 主题1分区1
- >传感器B - 主题1分区2
设备2
- >传感器A - 主题2分区1
- >传感器B - 主题2分区2
我想要一些pub/sub类型的行为.由于可以添加或移除设备,因此也可以添加或移除传感器.有没有办法创建这些主题和动态分区.
如果不是kafka,那么pub/sub将适合这种行为.
scalability real-time publish-subscribe bigdata apache-kafka
这是我的.h文件
当我运行此代码并选择一个文本字段时,一个带有问号的pickerview pop,但是当我选择问号时,我在文本字段中得到正确的值
#import <UIKit/UIKit.h>
#import "ScrollableViewController.h"
#import "MIBackgroundTapDelegate.h"
//@interface Activapc1 : UIViewController {
@interface Activapc1 : ScrollableViewController <MIBackgroundTapDelegate, UIPickerViewDelegate, UIPickerViewDataSource>{
UITextField *amplitude1;
UITextField *rate1;
UITextField *pulse_width1;
UITextField *impedance1;
IBOutlet UITextField *configuration;
NSArray *mode;
Run Code Online (Sandbox Code Playgroud)
}
@property (nonatomic, retain) IBOutlet UITextField *amplitude1;
@property (nonatomic, retain) IBOutlet UITextField *rate1;
@property (nonatomic, retain) IBOutlet UITextField *pulse_width1;
@property (nonatomic, retain) IBOutlet UITextField *impedance1;
-(IBAction)next;
-(IBAction)skip;
-(IBAction)home;
-(IBAction)select;
-(IBAction)textFieldDoneEditing:(id) sender;
@end
Run Code Online (Sandbox Code Playgroud)
这是.m文件
我无法理解为什么我会得到问号请帮助我
#import "Activapc1.h"
#import "dbsViewController.h"
#import "Activapc2.h"
#import "APCoption.h"
@implementation Activapc1
@synthesize amplitude1; …Run Code Online (Sandbox Code Playgroud) 我想从列表中返回类的对象(作为参数传递给方法).同时返回时我需要将对象强制转换为作为参数传递的类.我的问题是我尝试按照下面给出的但是它不正确,因为它给了我编译器错误"classToFind无法解析为类型"
private <T extends myClass> T findObject(List<JAXBElement<? extends myClass>> list,
Class<? extends myClass> classToFind) {
for (JAXBElement<? extends myClass> current : list) {
if(current.getClass() == classToFind) {
return (classToFind) currentClass; // error "classToFind cannot be resolved to a type"
}
}
return null;
}
Run Code Online (Sandbox Code Playgroud) 我正在通过使用查询从数据库中选择所有表
select table_name from all_tables where owner='XYZ' order by table_name
Run Code Online (Sandbox Code Playgroud)
但是上面的查询也返回了物化视图。我怎样才能只获得表而不得到物化视图
apache-kafka ×1
bigdata ×1
iphone ×1
java ×1
mysql ×1
oracle ×1
real-time ×1
scalability ×1
sql ×1
uipickerview ×1
xcode ×1