search

pipelinedb / pipeline_kafka

PipelineDB extension for Kafka support
Other
61 stars 22 forks source link

No have group_id in my consume_begin function #65

Closed luizkava closed 7 years ago

luizkava commented 7 years ago

After installed the kafka_exetension 0.9.3, the function consume_begin does not appears the group_id option.... pipeline_kafka.consume_begin(topic text, relation text, format text DEFAULT 'text'::text, delimiter text DEFAULT ' '::text, quote text DEFAULT NULL::text, escape text DEFAULT NULL::text, batchsize integer DEFAULT 1000, maxbytes integer DEFAULT 32000000, parallelism integer DEFAULT 1, timeout integer DEFAULT 250, start_offset bigint DEFAULT NULL::bigint)

luizkava commented 7 years ago

no one ?

derekjn commented 7 years ago

@luizkava can you explain a bit more about what the problem you're having? If you installed this over an older version of pipeline_kafka, you might want to try dropping pipeline_kafka and then recreating it with the latest version installed.

luizkava commented 7 years ago

Hi @derekjn , I have 2 servers with the same kafka version (I think), in the first server the function pipeline_kafka.consume_begin doesn't have the variable "group_id"... How do I know the pipeline_kafka version ?

derekjn commented 7 years ago

@luizkava you can check the version by entering \dx in a shell. But the problem you're having is that you have different versions of the extension installed, so you should just do a clean install and CREATE EXTENSION on each of your servers.

luizkava commented 7 years ago

@derekjn I've seen the versions, and it's the same on the servers (0.9.3), but I'll try your suggestion.

derekjn commented 7 years ago

@luizkava sounds good. If that doesn't work, just let us know and we'll keep at it until you're up and running.

luizkava commented 7 years ago

@derekjn thanks a lot, it's worked... I removed and installed the extension again...

regards.

derekjn commented 7 years ago

@luizkava great to hear! Let us know if you need anything else.