pipelinedb/pipeline_kafka

Issues

• cannot implemented kafka json meesage

  #98 opened 3 years ago by VisionaryAries
  0

• could not load library "/usr/pgsql-11/lib/pipeline_kafka.so" with PG 11 and pipelinedb 1.0 on Centos 7

  #85 opened 5 years ago by vnnw
  1

• ERROR: could not load library "/usr/local/lib/pipelinedb/lib/pipelinedb/pipeline_kafka.so"

  #63 opened 7 years ago by mmcalli
  5

• pipeline_kafka编译失败问题

  #96 opened 5 years ago by AzraelJi
  1

• 请问1.0.0插件支持kafka版本号是多少呢？

  #97 opened 5 years ago by AzraelJi
  1

• pipeline_kafka make error

  #95 opened 5 years ago by pecanNBU
  1

• not works with pg11

  #94 opened 5 years ago by yyscamper
  2

• release debian package

  #93 opened 5 years ago by yyscamper
  0

• no release since 26 Dec 2016

  #92 opened 5 years ago by yyscamper
  0

• Consumer does not automatically reconnect to Kafka

  #91 opened 5 years ago by analytik
  0

• Consumer format settings are not displayed correctly

  #90 opened 5 years ago by analytik
  0

• SASL_PLAINTEXT error

  #89 opened 5 years ago by guitmz
  0

• undefined symbol: sasl_client_step

  #88 opened 5 years ago by sangli00
  0

• Need help!!ERROR:[pipeline_kafka] y_kk_stream <- xxxxxxxx(pid xxxx) :failed to acquire metadata:local:timed out

  #87 opened 5 years ago by val-sy
  0

• Install for pg 11: pipeline_kafka.c:32:20: fatal error: config.h: No such file or directory

  #86 opened 5 years ago by yurinek
  1

• Write to (non-stream) relation

  #84 opened 5 years ago by jamessewell
  0

• undefined symbol: LZ4F_compressUpdate

  #83 opened 5 years ago by destinokm
  0

• compile error：stream_copy_hook not defined

  #82 opened 5 years ago by miaojianxin
  4

• Compile src code failed !

  #81 opened 5 years ago by GangLiCN
  1

• PipelineDB 1.0 compatibility

  #78 opened 5 years ago by ikingnet
  11

• Expose consumer niceness configuration parameter

  #79 opened 6 years ago by derekjn
  0

• pipeline_kafka.consume_begin returns "failure"

  #66 opened 6 years ago by Sudmota
  6

• Only support 0.9.1 kafka?

  #77 opened 6 years ago by sangli00
  1

• Need modify Makefile

  #76 opened 6 years ago by sangli00
  0

• Segfault when SSL certificates not found

  #73 opened 7 years ago by michaelsauter
  3

• Use security.protocol=SASL_PLAINTEXT error

  #75 opened 6 years ago by gb198871
  1

• After pipeline_kafka.consume_begin , the pipelinedb error

  #74 opened 6 years ago by weiranth
  0

• LOG: worker process: worker0 [pipeline] (PID 16887) was terminated by signal 11: Segmentation fault

  #72 opened 7 years ago by gb198871
  8

• New features: support pipeline_kafka.consume_status()

  #71 opened 7 years ago by EamonZhang
  0

• support for -o flag like in kafkacat

  #70 opened 7 years ago by derekjn
  3

• Add flag to enable commit before COPY execution

  #69 opened 7 years ago by derekjn
  2

• Kafka SSL

  #67 opened 7 years ago by derekjn
  11

• Long consumer_config keys/values may be truncated

  #68 opened 7 years ago by derekjn
  0

• No have group_id in my consume_begin function

  #65 opened 7 years ago by luizkava
  8

• Support fixed-length prefix for partitioned consumer keys

  #64 opened 7 years ago by derekjn
  0

• Unable to read data from kafka

  #59 opened 7 years ago by jayesh4192
  14

• Add node-level sharding to grouped consumer

  #54 opened 7 years ago by derekjn
  0

• Kafka extension function pipeline_kafka.add_broker() always returns success

  #62 opened 7 years ago by sfkeller
  0

• Partition offsets ignored when using consume_begin()

  #60 opened 7 years ago by nielsdraaisma
  0

• Add lag monitoring

  #55 opened 7 years ago by derekjn
  0

• UTC Timestamp doesnt work

  #58 opened 7 years ago by devsschmidt
  2

• Improvements

  #57 opened 7 years ago by simplesteph
  3

• Add parallelism to grouped consumer

  #53 opened 7 years ago by derekjn
  0

• Memory leak?

  #52 opened 7 years ago by derekjn
  1

• Release packages

  #50 opened 8 years ago by derekjn
  1

• Rework Kafka -> COPY path

  #51 opened 8 years ago by derekjn
  2

• Tests for producer

  #49 opened 8 years ago by usmanm
  0

• Ignore non-existent streams in stream partitioned mode

  #48 opened 8 years ago by usmanm
  0

• Deadlock in consume_begin

  #44 opened 8 years ago by AndreyNudko
  1

• is_zk_lock_held incorrectly returns false on error

  #45 opened 8 years ago by derekjn
  0