public class GSRKinesisPubsubClient extends Object
Constructor and Description |
---|
GSRKinesisPubsubClient(Properties properties) |
Modifier and Type | Method and Description |
---|---|
void |
createStream(String stream,
int shards,
Properties props) |
List<Object> |
readAllMessages(String streamName) |
void |
sendMessage(String schema,
String streamName,
org.apache.avro.generic.GenericRecord msg) |
public GSRKinesisPubsubClient(Properties properties)
public void sendMessage(String schema, String streamName, org.apache.avro.generic.GenericRecord msg)
public List<Object> readAllMessages(String streamName) throws Exception
Exception
public void createStream(String stream, int shards, Properties props) throws Exception
Exception
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.