[GitHub] [pulsar] gmethvin commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message
gmethvin commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message URL: https://github.com/apache/pulsar/issues/5006#issuecomment-524182636 I assume he's using 2.4.0 since that's the version pulsar4s is using now. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message
sijie commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message URL: https://github.com/apache/pulsar/issues/5006#issuecomment-524181934 @KannarFr what is the version of your client? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on issue #4890: [pulsar-sql] Handle schema not found
sijie commented on issue #4890: [pulsar-sql] Handle schema not found URL: https://github.com/apache/pulsar/pull/4890#issuecomment-524180777 @mingfang > 3-Repeat steps 1 and 2. In step 2 I would see this error Do you mean you stop the generator and rerun it again? Or did you just rerun step2? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie closed issue #4998: [BUILD FAILURE] pulsar-broker-auth-athenz of 2.5.0-SNAPSHOT[master], due to wrong maven repository
sijie closed issue #4998: [BUILD FAILURE] pulsar-broker-auth-athenz of 2.5.0-SNAPSHOT[master], due to wrong maven repository URL: https://github.com/apache/pulsar/issues/4998 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (JAVA API) and Sink (JAVA API) for the following operations: - [ ] Run a connector (create, start, localrun) - [ ] Monitor a connector (list, get, status) - [ ] Upgrade a connector (update) - [ ] Stop a connector (stop) - [ ] Restart a connector (restart) - [ ] Delete a connector (delete) ### Debug - [ ] (8/28) Write a tech blog ## Builtin connector (26) ### Source connector Provide examples for the following source connectors: - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector Provide examples for the following sink connectors: - [ ] Aerospike - [] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [ ] Kafka - [ ] MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (JAVA API) and Sink (JAVA API) for the following operations: - [ ] Run a connector (create, start, localrun) - [ ] Monitor a connector (list, get, status) - [ ] Upgrade a connector (update) - [ ] Stop a connector (stop) - [ ] Restart a connector (restart) - [ ] Delete a connector (delete) ### Debug - [ ] (8/28) Write a tech blog ## Builtin connector (26) ### Source connector Provide examples for the following source connectors: - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector Provide examples for the following sink connectors: - [ ] Aerospike - [] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [ ] Kafka - [ ] MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [x] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [x] ElasticSearch - [ ] Flume - [ ] HBase - [x] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [x] JDBC - [ ] Kafka - [x] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [x] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [x] ElasticSearch - [ ] Flume - [ ] HBase - [x] HDFS2 - [x] HDFS3 - [ ] InfluxDB - [x] JDBC - [ ] Kafka - [x] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [x] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [x] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [x] JDBC - [ ] Kafka - [ ] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [x] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [x] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [x] JDBC - [ ] Kafka - [x] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [x] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [x] Cassandra - [x] ElasticSearch - [ ] Flume - [ ] HBase - [x] HDFS2 - [x] HDFS3 - [ ] InfluxDB - [x] JDBC - [ ] Kafka - [x] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [x] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [ ] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [x] JDBC - [ ] Kafka - [ ] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [x] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [x] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [ ] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [x] JDBC - [ ] Kafka - [ ] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [x] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [x] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [ ] ElasticSearch - [x] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [x] JDBC - [ ] Kafka - [ ] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [x] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [x] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [ ] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [x] JDBC - [ ] Kafka - [ ] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [x] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [x] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [ ] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [ ] JDBC - [ ] Kafka - [ ] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [ ] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [ ] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [ ] JDBC - [ ] Kafka - [ ] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [x] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [x] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [ ] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [ ] JDBC - [ ] Kafka - [ ] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] frank-dkvan commented on issue #4998: [BUILD FAILURE] pulsar-broker-auth-athenz of 2.5.0-SNAPSHOT[master], due to wrong maven repository
frank-dkvan commented on issue #4998: [BUILD FAILURE] pulsar-broker-auth-athenz of 2.5.0-SNAPSHOT[master], due to wrong maven repository URL: https://github.com/apache/pulsar/issues/4998#issuecomment-524165789 I think this thread can be closed. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] frank-dkvan commented on issue #4998: [BUILD FAILURE] pulsar-broker-auth-athenz of 2.5.0-SNAPSHOT[master], due to wrong maven repository
frank-dkvan commented on issue #4998: [BUILD FAILURE] pulsar-broker-auth-athenz of 2.5.0-SNAPSHOT[master], due to wrong maven repository URL: https://github.com/apache/pulsar/issues/4998#issuecomment-524165706 @sijie it works! great, thanks! I just paste this repository into sub-project "pulsar-broker-auth-athenz" POM file. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] nkurihar commented on a change in pull request #5018: Added powered-by page
nkurihar commented on a change in pull request #5018: Added powered-by page
URL: https://github.com/apache/pulsar/pull/5018#discussion_r316968599
##
File path: site2/website/data/users.js
##
@@ -0,0 +1,127 @@
+module.exports = [
+{
+name: 'Narvar',
+url: 'https://corp.narvar.com/',
+logo:
'https://corp.narvar.com/wp-content/themes/narvarinc/dist/images/narvar-logo.svg',
+},
+{
+name: 'Giggso',
+url: 'https://giggso.com/',
+logo:
'https://pbs.twimg.com/profile_banners/4179602009/1470596851/600x200'
+},
+{
+name: 'STICorp',
+url: 'https://www.sticorp.com.br/',
+logo:
'https://www.sticorp.com.br/wp-content/uploads/2015/09/logo-horizontal.png',
+},
+{
+name: 'Verizon Media',
+url: 'https://www.verizonmedia.com/',
+logo:
'https://upload.wikimedia.org/wikipedia/commons/thumb/0/09/Verizon_Media_2019_logo.svg/1200px-Verizon_Media_2019_logo.svg.png'
+},
+{
+name: 'Yahoo! Japan',
Review comment:
Thanks!
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] mingfang removed a comment on issue #3822: Add a sink connector to export stream data to Alluxio
mingfang removed a comment on issue #3822: Add a sink connector to export stream data to Alluxio URL: https://github.com/apache/pulsar/issues/3822#issuecomment-524164298 I think having an Alluxio Source would be great too. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Monica-zy commented on a change in pull request #5014: [doc] Improve Pulsar Security Overview
Monica-zy commented on a change in pull request #5014: [doc] Improve Pulsar Security Overview URL: https://github.com/apache/pulsar/pull/5014#discussion_r316967689 ## File path: site2/docs/security-overview.md ## @@ -4,28 +4,23 @@ title: Pulsar Security Overview sidebar_label: Overview --- -Apache Pulsar is the central message bus for a business. It is frequently used to store mission-critical data, and therefore enabling security features are crucial. +As the central message bus for a business, Apache Pulsar is frequently used for storing mission-critical data. Therefore, enabling security features in Pulsar is crucial. -By default, there is no encryption, authentication, or authorization configured. Any client can communicate to Apache Pulsar via plain text service urls. -It is critical that access via these plain text service urls is restricted to trusted clients only. Network segmentation and/or authorization ACLs can be used -to restrict access to trusted IPs in such cases. If neither is used, the cluster is wide open and can be accessed by anyone. +By default, Pulsar configures no encryption, authentication, or authorization. Any client can communicate to Apache Pulsar via plain text service urls. So we must ensure that Pulsar accessing via these plain text service urls is restricted to trusted clients only. In such cases, you can use Network segmentation and/or authorization ACLs to restrict access to trusted IPs. If you use neither, the state of cluster is wide open and anyone can access the cluster. -Pulsar supports a pluggable authentication mechanism that Pulsar clients can use to authenticate with brokers and proxies. Pulsar -can also be configured to support multiple authentication sources. +Pulsar supports a pluggable authentication mechanism. And Pulsar clients use this mechanism to authenticate with brokers and proxies. You can also configure Pulsar to support multiple authentication sources. -It is strongly recommended to secure the service components in your Apache Pulsar deployment. +You'd better secure the service components in your Apache Pulsar deployment. ## Role Tokens -In Pulsar, a *role* is a string, like `admin` or `app1`, that can represent a single client or multiple clients. Roles are used to control permission for clients -to produce or consume from certain topics, administer the configuration for tenants, and more. +In Pulsar, a *role* is a string, like `admin` or `app1`, which can represent one or more clients. You can use roles to control permission for clients to produce or consume from certain topics, administer the configuration for tenants, and so on. -Apache Pulsar uses a [Authentication Provider](#authentication-providers) to establish the identity of a client and then assign that client a *role token*. This -role token is then used for [Authorization and ACLs](security-authorization.md) to determine what the client is authorized to do. +Apache Pulsar uses the [Authentication Provider](#authentication-providers) to establish the identity of a client and then assign a *role token* to that client. This role token is then used for [Authorization and ACLs](security-authorization.md) to determine what the client is authorized to do. ## Authentication Providers -Currently Pulsar supports two authentication providers: +Currently Pulsar supports three authentication providers: Review comment: Ok, like this?  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar-client-node.wiki] branch master updated: Updated Release process (markdown)
This is an automated email from the ASF dual-hosted git repository. massakam pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.wiki.git The following commit(s) were added to refs/heads/master by this push: new 51e8c80 Updated Release process (markdown) 51e8c80 is described below commit 51e8c808ca62ad0cd1f9b68d2ed38e839ad07922 Author: Masahiro Sakamoto AuthorDate: Fri Aug 23 13:06:19 2019 +0900 Updated Release process (markdown) --- Release-process.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Release-process.md b/Release-process.md index 4c46985..077bc63 100644 --- a/Release-process.md +++ b/Release-process.md @@ -62,7 +62,7 @@ https://pulsar.apache.org/docs/en/client-libraries-cpp/ Install dependent npm modules and build Pulsar Node.js client: ```sh -$ npm install +$ npm ci ``` After the build, inspect the artifacts:
[GitHub] [pulsar] mingfang commented on issue #3822: Add a sink connector to export stream data to Alluxio
mingfang commented on issue #3822: Add a sink connector to export stream data to Alluxio URL: https://github.com/apache/pulsar/issues/3822#issuecomment-524164298 I think having an Alluxio Source would be great too. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details of Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [ ] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [ ] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [ ] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [ ] JDBC - [ ] Kafka - [ ] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 ## Plans for updating Pulsar Connector Guide TO DO tasks for ## Use ### Use a connector - [ ] (8/23) Provide technical details for "Use non-builtin connector" section ### Run/Monitor/Upgrade/Stop/Restart/Delete a connector Provide technical details for Source (REST API + JAVA API) and Sink (REST API + JAVA API) for the following operations: - [ ] (8/26) Run a connector (create, start, localrun) - [ ] (8/27) Monitor a connector (list, get, status) - [ ] (8/28) Upgrade a connector (update) - [ ] (8/29) Stop a connector (stop) - [ ] (8/30) Restart a connector (restart) - [ ] (9/2) Delete a connector (delete) ### Debug - [ ] (9/3) Write a tech blog ## Builtin connector (26) ### Source connector (10) Provide examples for the following source connectors: - [ ] (9/4) Canal - [ ] (9/5) Data-generator - [ ] File - [ ] Flume - [ ] Twitter Firehose - [ ] Kafka - [ ] Kafka-connect-adaptor - [ ] Kinesis - [ ] Netty - [ ] RabbitMQ ### Sink connector (14) Provide examples for the following sink connectors: - [ ] Aerospike - [ ] Cassandra - [ ] ElasticSearch - [ ] Flume - [ ] HBase - [ ] HDFS2 - [ ] HDFS3 - [ ] InfluxDB - [ ] JDBC - [ ] Kafka - [ ] (9/30) MongoDB - [ ] RabbitMQ - [ ] Redis - [ ] Solr This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar-client-node] annotated tag v0.0.1-rc.1 updated (c7eec7e -> c93d682)
This is an automated email from the ASF dual-hosted git repository. massakam pushed a change to annotated tag v0.0.1-rc.1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git. *** WARNING: tag v0.0.1-rc.1 was modified! *** from c7eec7e (commit) to c93d682 (tag) tagging c7eec7e1e86237b22083344c719cf9f47cd46061 (commit) by Masahiro Sakamoto on Fri Aug 23 12:35:40 2019 +0900 - Log - 0.0.1-rc.1 --- No new revisions were added by this update. Summary of changes:
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880
## Plans for updating Pulsar Connector Guide
TO DO tasks for
## Use
### Use a connector
- [ ] (8/23) Provide technical details for "Use non-builtin connector"
section
### Run a connector (create, start, localrun)
- [ ] (8/26) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
### Monitor a connector (list, get, status)
- [ ] (8/27) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Upgrade a connector (update)
- [ ] (8/28) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Stop a connector (stop)
- [ ] (8/29) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Restart a connector (restart)
- [ ] (8/30) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Delete a connector (delete)
- [ ] (9/2) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
### Debug
- [ ] (9/3) Write a tech blog
## Builtin connector (26)
### Source connector (10)
Provide examples for the following source connectors:
- [ ] (9/4) Canal
- [ ] (9/5) Data-generator
- [ ] File
- [ ] Flume
- [ ] Twitter Firehose
- [ ] Kafka
- [ ] Kafka-connect-adaptor
- [ ] Kinesis
- [ ] Netty
- [ ] RabbitMQ
### Sink connector (14)
Provide examples for the following sink connectors:
- [ ] Aerospike
- [ ] Cassandra
- [ ] ElasticSearch
- [ ] Flume
- [ ] HBase
- [ ] HDFS2
- [ ] HDFS3
- [ ] InfluxDB
- [ ] JDBC
- [ ] Kafka
- [ ] (9/30) MongoDB
- [ ] RabbitMQ
- [ ] Redis
- [ ] Solr
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880
## Plans for updating Pulsar Connector Guide
TO DO tasks for
## Use
### Use a connector
- [ ] (8/23) Provide technical details for "Use non-builtin connector"
section
### Run a connector (create, start, localrun)
- [ ] (8/26) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
### Monitor a connector (list, get, status)
- [ ] (8/27) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Upgrade a connector (update)
- [ ] (8/28) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Stop a connector (stop)
- [ ] (8/29) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Restart a connector (restart)
- [ ] (8/30) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Delete a connector (delete)
- [ ] (9/2) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
### Debug
- [ ] (9/3) Write a tech blog
## Builtin connector (26)
### Source connector (10)
- [ ] (9/4) Provide examples of Canal
- [ ] (9/5) Provide examples of Data-generator
- [ ] Provide examples of File
- [ ] Provide examples of Flume
- [ ] Provide examples of Twitter Firehose
- [ ] Provide examples of Kafka
- [ ] Provide examples of Kafka-connect-adaptor
- [ ] Provide examples of Kinesis
- [ ] Provide examples of Netty
- [ ] Provide examples of RabbitMQ
### Sink connector (14)
- [ ] Provide examples of Aerospike
- [ ] Provide examples of Cassandra
- [ ] Provide examples of ElasticSearch
- [ ] Provide examples of Flume
- [ ] Provide examples of HBase
- [ ] Provide examples of HDFS2
- [ ] Provide examples of HDFS3
- [ ] Provide examples of InfluxDB
- [ ] Provide examples of JDBC
- [ ] Provide examples of Kafka
- [ ] (9/30) Provide examples of MongoDB
- [ ] Provide examples of RabbitMQ
- [ ] Provide examples of Redis
- [ ] Provide examples of Solr
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880
## Plans for updating Pulsar Connector Guide
TO DO tasks for
## Use
### Use a connector
- [ ] (8/23) Provide technical details for "Use non-builtin connector"
section
### Run a connector (create, start, localrun)
- [ ] (8/26) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
### Monitor a connector (list, get, status)
- [ ] (8/27) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Upgrade a connector (update)
- [ ] (8/28) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Stop a connector (stop)
- [ ] (8/29) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Restart a connector (restart)
- [ ] (8/30) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Delete a connector (delete)
- [ ] (9/2) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
### Debug
- [ ] (9/3) Write a tech blog
## Builtin connector (26)
### Source connector (10)
- [ ] (9/4) Provide examples of Canal
- [ ] Provide examples of Data-generator
- [ ] Provide examples of File
- [ ] Provide examples of Flume
- [ ] Provide examples of Twitter Firehose
- [ ] Provide examples of Kafka
- [ ] Provide examples of Kafka-connect-adaptor
- [ ] Provide examples of Kinesis
- [ ] Provide examples of Netty
- [ ] Provide examples of RabbitMQ
### Sink connector (14)
- [ ] Provide examples of Aerospike
- [ ] Provide examples of Cassandra
- [ ] Provide examples of ElasticSearch
- [ ] Provide examples of Flume
- [ ] Provide examples of HBase
- [ ] Provide examples of HDFS2
- [ ] Provide examples of HDFS3
- [ ] Provide examples of InfluxDB
- [ ] Provide examples of JDBC
- [ ] Provide examples of Kafka
- [ ] Provide examples of MongoDB
- [ ] Provide examples of RabbitMQ
- [ ] Provide examples of Redis
- [ ] Provide examples of Solr
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524145717 ## Plans for updating Pulsar Connector Guide TO DO tasks for @Anonymitaet ## Overview - [ ] Add worker section - [ ] Add architecture section ## Use ### Use a connector - [ ] Add contents for "Use builtin connector" section - [ ] Update "Configure a connector" section TBD This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880
## Plans for updating Pulsar Connector Guide
TO DO tasks for
## Use
### Use a connector
- [ ] (8/23) Provide technical details for "Use non-builtin connector"
section
### Run a connector (create, start, localrun)
- [ ] (8/24) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
### Monitor a connector (list, get, status)
- [ ] (8/25) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Upgrade a connector (update)
- [ ] (8/26) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Stop a connector (stop)
- [ ] (8/27) Provide technical details for Source (REST API + JAVA API) and
Sink (REST API + JAVA API)
Restart a connector (restart)
- [ ] Provide technical details for Source (REST API + JAVA API) and Sink
(REST API + JAVA API)
Delete a connector (delete)
- [ ] Provide technical details for Source (REST API + JAVA API) and Sink
(REST API + JAVA API)
### Debug
- [ ] Write a tech blog
## Builtin connector (26)
### Source connector (10)
- [ ] Provide examples of Canal
- [ ] Provide examples of Data-generator
- [ ] Provide examples of File
- [ ] Provide examples of Flume
- [ ] Provide examples of Twitter Firehose
- [ ] Provide examples of Kafka
- [ ] Provide examples of Kafka-connect-adaptor
- [ ] Provide examples of Kinesis
- [ ] Provide examples of Netty
- [ ] Provide examples of RabbitMQ
### Sink connector (14)
- [ ] Provide examples of Aerospike
- [ ] Provide examples of Cassandra
- [ ] Provide examples of ElasticSearch
- [ ] Provide examples of Flume
- [ ] Provide examples of HBase
- [ ] Provide examples of HDFS2
- [ ] Provide examples of HDFS3
- [ ] Provide examples of InfluxDB
- [ ] Provide examples of JDBC
- [ ] Provide examples of Kafka
- [ ] Provide examples of MongoDB
- [ ] Provide examples of RabbitMQ
- [ ] Provide examples of Redis
- [ ] Provide examples of Solr
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524145717 #@ Plans for updating Pulsar Connector Guide TO DO tasks for @Anonymitaet ## Overview - [ ] Add worker section - [ ] Add architecture section ## Use ### Use a connector - [ ] Add contents for "Use builtin connector" section - [ ] Update "Configure a connector" section TBD This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar-client-node] 01/01: 0.0.1-rc.1
This is an automated email from the ASF dual-hosted git repository.
massakam pushed a commit to branch branch-0.0
in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git
commit c7eec7e1e86237b22083344c719cf9f47cd46061
Author: Masahiro Sakamoto
AuthorDate: Fri Aug 23 12:35:40 2019 +0900
0.0.1-rc.1
---
package-lock.json | 2 +-
package.json | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/package-lock.json b/package-lock.json
index 4a8725c..4f4c4ac 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -1,6 +1,6 @@
{
"name": "pulsar-client",
- "version": "0.0.1-rc.0",
+ "version": "0.0.1-rc.1",
"lockfileVersion": 1,
"requires": true,
"dependencies": {
diff --git a/package.json b/package.json
index 5798bec..747eed9 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
{
"name": "pulsar-client",
- "version": "0.0.1-rc.0",
+ "version": "0.0.1-rc.1",
"description": "Pulsar Node.js client",
"main": "index.js",
"directories": {
[pulsar-client-node] branch branch-0.0 created (now c7eec7e)
This is an automated email from the ASF dual-hosted git repository. massakam pushed a change to branch branch-0.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git. at c7eec7e 0.0.1-rc.1 This branch includes the following new commits: new c7eec7e 0.0.1-rc.1 The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880
## Plans for updating Pulsar Connector Guide
TO DO tasks for
## Use
### Use a connector
- [ ] Provide technical details for "Use non-builtin connector" section
### Run a connector (create, start, localrun)
- [ ] Provide technical details for Source (REST API + JAVA API)
- [ ] Provide technical details for Sink (REST API + JAVA API)
### Monitor a connector (list, get, status)
- [ ] Provide technical details for Source (REST API + JAVA API)
- [ ] Provide technical details for Sink (REST API + JAVA API)
Upgrade a connector (update)
- [ ] Provide technical details for Source (REST API + JAVA API)
- [ ] Provide technical details for Sink (REST API + JAVA API)
Stop a connector (stop)
- [ ] Provide technical details for Source (REST API + JAVA API)
- [ ] Provide technical details for Sink (REST API + JAVA API)
Restart a connector (restart)
- [ ] Provide technical details for Source (REST API + JAVA API)
- [ ] Provide technical details for Sink (REST API + JAVA API)
Delete a connector (delete)
- [ ] Provide technical details for Source (REST API + JAVA API)
- [ ] Provide technical details for Sink (REST API + JAVA API)
### Debug
- [ ] Write a tech blog
## Builtin connector (26)
### Source connector (10)
- [ ] Provide examples of Canal
- [ ] Provide examples of Data-generator
- [ ] Provide examples of File
- [ ] Provide examples of Flume
- [ ] Provide examples of Twitter Firehose
- [ ] Provide examples of Kafka
- [ ] Provide examples of Kafka-connect-adaptor
- [ ] Provide examples of Kinesis
- [ ] Provide examples of Netty
- [ ] Provide examples of RabbitMQ
### Sink connector (14)
- [ ] Provide examples of Aerospike
- [ ] Provide examples of Cassandra
- [ ] Provide examples of ElasticSearch
- [ ] Provide examples of Flume
- [ ] Provide examples of HBase
- [ ] Provide examples of HDFS2
- [ ] Provide examples of HDFS3
- [ ] Provide examples of InfluxDB
- [ ] Provide examples of JDBC
- [ ] Provide examples of Kafka
- [ ] Provide examples of MongoDB
- [ ] Provide examples of RabbitMQ
- [ ] Provide examples of Redis
- [ ] Provide examples of Solr
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] mingfang commented on issue #4890: [pulsar-sql] Handle schema not found
mingfang commented on issue #4890: [pulsar-sql] Handle schema not found
URL: https://github.com/apache/pulsar/pull/4890#issuecomment-524159615
I'm not sure it this is related but I'm seeing the "Table has no columns"
error when running the Pulsar SQL tutorial here
https://pulsar.apache.org/docs/en/sql-getting-started/.
Steps to recreate the problem
1-Generate some data by running this command for a minute and then kill it.
`./bin/pulsar-admin sources localrun --name generator --destinationTopicName
generator_test -a connectors/pulsar-io-data-generator-2.4.0.nar`
2-Use Pulsar SQL to "consume" the data
`select * from pulsar."public/default".generator_test;`
3-Repeat steps 1 and 2. In step 2 I would see this error
`Query 20190823_01_00067_sw7tk failed: Table has no columns:
pulsar:PulsarTableHandle{connectorId=pulsar, schemaName=public/default,
tableName=generator_test, topicName=generator_test}`
I can reproduce this error 100% of the time.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143612 I plan to rewrite this guide, the **Updated Structure of Pulsar Connector Guide** is as below. (Will add contents in the red box or highlighted in yellow)  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] tuteng commented on issue #5008: [Pulsar IO]Support reload Source and Sink for Pulsar IO
tuteng commented on issue #5008: [Pulsar IO]Support reload Source and Sink for Pulsar IO URL: https://github.com/apache/pulsar/pull/5008#issuecomment-524158685 > The endpoints add here needs to include authorization as not any using should be allowed to do this. I would say only super users should be allowed to perform this operation. @jerrypeng PTAL This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143612 I plan to rewrite this guide, the **Updated Structure of Pulsar Connector Guide** is as below. (Will add contents in the red box or highlighted in yellow)  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524145717 # Plans for updating Pulsar Connector Guide TO DO tasks for @Anonymitaet This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524149120 PRs related to this issue: [placeholder] This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524145717 Plans of This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch github_exp1 updated (40f9817 -> ee08d7a)
This is an automated email from the ASF dual-hosted git repository. aahmed pushed a change to branch github_exp1 in repository https://gitbox.apache.org/repos/asf/pulsar.git. discard 40f9817 Add Github CI workflow add ee08d7a Add Github CI workflow This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (40f9817) \ N -- N -- N refs/heads/github_exp1 (ee08d7a) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .github/workflows/ci.yaml | 21 - 1 file changed, 20 insertions(+), 1 deletion(-)
[GitHub] [pulsar] zubchenok commented on issue #5025: ProducerStats invalid stat values
zubchenok commented on issue #5025: ProducerStats invalid stat values URL: https://github.com/apache/pulsar/issues/5025#issuecomment-524153385 https://github.com/apache/pulsar/blob/958dcfee764285f12044d2b626960968569c7302/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java#L194 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] zubchenok opened a new issue #5025: ProducerStats invalid stat values
zubchenok opened a new issue #5025: ProducerStats invalid stat values URL: https://github.com/apache/pulsar/issues/5025 Producer latency stat values are actually in microseconds, but ProducerStats method names state that it should be milliseconds. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se opened a new pull request #5024: Improve Port Manager
aahmed-se opened a new pull request #5024: Improve Port Manager URL: https://github.com/apache/pulsar/pull/5024 This is an improvement to the code to check for free ports. This is to avoid test errors in the ci env. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch port_manager created (now 9e55a68)
This is an automated email from the ASF dual-hosted git repository. aahmed pushed a change to branch port_manager in repository https://gitbox.apache.org/repos/asf/pulsar.git. at 9e55a68 Fix Port Manager This branch includes the following new commits: new 9e55a68 Fix Port Manager The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[pulsar] 01/01: Fix Port Manager
This is an automated email from the ASF dual-hosted git repository.
aahmed pushed a commit to branch port_manager
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 9e55a6877c03ede6b427b051af77a8a19fa65de3
Author: Ali Ahmed
AuthorDate: Thu Aug 22 18:23:42 2019 -0700
Fix Port Manager
---
.../src/test/java/org/apache/bookkeeper/test/PortManager.java | 8 ++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git
a/managed-ledger/src/test/java/org/apache/bookkeeper/test/PortManager.java
b/managed-ledger/src/test/java/org/apache/bookkeeper/test/PortManager.java
index a18cc04..65c11f5 100644
--- a/managed-ledger/src/test/java/org/apache/bookkeeper/test/PortManager.java
+++ b/managed-ledger/src/test/java/org/apache/bookkeeper/test/PortManager.java
@@ -21,6 +21,8 @@ package org.apache.bookkeeper.test;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.nio.CharBuffer;
import java.nio.channels.FileChannel;
@@ -37,7 +39,7 @@ public class PortManager {
private static final String lockFilename =
System.getProperty("test.lockFilename",
"/tmp/pulsar-test-port-manager.lock");
-private static final int basePort =
Integer.valueOf(System.getProperty("test.basePort", "15000"));
+private static final int basePort =
Integer.parseInt(System.getProperty("test.basePort", "15000"));
private static final int maxPort = 32000;
@@ -95,7 +97,9 @@ public class PortManager {
port = basePort;
}
-try (ServerSocket ss = new ServerSocket(port)) {
+try (ServerSocket ss = new ServerSocket()) {
+ss.setReuseAddress(false);
+ss.bind(new
InetSocketAddress(InetAddress.getByName("localhost"), port), 1);
ss.close();
// Give it some time to truly close the connection
Thread.sleep(100);
[GitHub] [pulsar] congbobo184 commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message
congbobo184 commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message URL: https://github.com/apache/pulsar/issues/5006#issuecomment-524152292 the exception seem to that client didn't send the schema version to broker This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] merlimat commented on a change in pull request #5018: Added powered-by page
merlimat commented on a change in pull request #5018: Added powered-by page
URL: https://github.com/apache/pulsar/pull/5018#discussion_r316957700
##
File path: site2/website/data/users.js
##
@@ -0,0 +1,127 @@
+module.exports = [
+{
+name: 'Narvar',
+url: 'https://corp.narvar.com/',
+logo:
'https://corp.narvar.com/wp-content/themes/narvarinc/dist/images/narvar-logo.svg',
+},
+{
+name: 'Giggso',
+url: 'https://giggso.com/',
+logo:
'https://pbs.twimg.com/profile_banners/4179602009/1470596851/600x200'
+},
+{
+name: 'STICorp',
+url: 'https://www.sticorp.com.br/',
+logo:
'https://www.sticorp.com.br/wp-content/uploads/2015/09/logo-horizontal.png',
+},
+{
+name: 'Verizon Media',
+url: 'https://www.verizonmedia.com/',
+logo:
'https://upload.wikimedia.org/wikipedia/commons/thumb/0/09/Verizon_Media_2019_logo.svg/1200px-Verizon_Media_2019_logo.svg.png'
+},
+{
+name: 'Yahoo! Japan',
Review comment:
Sure, fixed
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143612 I plan to rewrite this guide, the **Updated Structure of Pulsar Connector Guide** is as below. (Will add contents in the red box or highlighted in yellow)  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] zymap opened a new pull request #5023: `hasMessageAvailable` should return false when Reader read from latest messages
zymap opened a new pull request #5023: `hasMessageAvailable` should return false when Reader read from latest messages URL: https://github.com/apache/pulsar/pull/5023 Fixes #4912 *Motivation* When the reader reads from the latest message, `hasMessageAvailable` will timeout or hang on. *Modifications* Make `lastDequeuedMessage` start position should keep with `startMessageId`. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143612 I plan to re-write this guide, the **Updated Structure of Pulsar Connector Guide** is as below. (Will add contents in the red box or highlighted in yellow)  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524150894 @sijie @tuteng could you please help review the **Updated Structure of Pulsar Connector Guide**? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524150894 @sijie @tuteng could you please help review the "Updated Structure of Pulsar Connector Guide"? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143612 I plan to update the Structure of Pulsar Connector Guide as below. Will add contents in the red box or highlighted in yellow.  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524149120 [placeholder for other info] This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524145717 PRs related to this issue: [placeholder] This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 Plans of updating Pulsar Connector Guide: This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 Plans to update Pulsar Connector Guide: This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar-client-go] wolfstudy opened a new pull request #61: [issue:60] Fix partition topic message router logic
wolfstudy opened a new pull request #61: [issue:60] Fix partition topic message router logic URL: https://github.com/apache/pulsar-client-go/pull/61 Signed-off-by: xiaolong.ran Fixes #60 ### Motivation - Fix partition topic message router logic - Fix permits of flow data race This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Monica-zy removed a comment on issue #5014: [doc] Improve Pulsar Security Overview
Monica-zy removed a comment on issue #5014: [doc] Improve Pulsar Security Overview URL: https://github.com/apache/pulsar/pull/5014#issuecomment-523856140 @Anonymitaet Please spare some time to help review whether the refinement this way is OK, thank you~ This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524145717 [placeholder for other related info] This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143612 I plan to update the Structure of Pulsar Connector Guide as below.  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143612 I plan to update the Structure of Pulsar Connector Guide as below.  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143880 PRs related to this issue: [placeholder] This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] zymap commented on issue #5001: [Pulsar-sql]Using pulsar SQL query messages will appear `NoSuchLedger` when zk root directory changed
zymap commented on issue #5001: [Pulsar-sql]Using pulsar SQL query messages will appear `NoSuchLedger` when zk root directory changed URL: https://github.com/apache/pulsar/pull/5001#issuecomment-524143816 @sijie @jiazhai thanks. I will add it. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet edited a comment on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143612 I plan to update the Structure of Pulsar Connector Guide as below:  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143612 Updated Structure of Pulsar Connector Guide:  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide
Anonymitaet commented on issue #5015: [Doc] Update Pulsar Connector Guide URL: https://github.com/apache/pulsar/issues/5015#issuecomment-524143470 Old Structure of Pulsar Connector Guide:  This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] jiazhai commented on issue #5001: [Pulsar-sql]Using pulsar SQL query messages will appear `NoSuchLedger` when zk root directory changed
jiazhai commented on issue #5001: [Pulsar-sql]Using pulsar SQL query messages will appear `NoSuchLedger` when zk root directory changed URL: https://github.com/apache/pulsar/pull/5001#issuecomment-524139795 @zymap As Sijie suggested we could add tests for ManagedLedger firstly, this would cover most of the code changes. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar-client-node] branch master updated: Change initial version to 0.0.1
This is an automated email from the ASF dual-hosted git repository.
nkurihar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-node.git
The following commit(s) were added to refs/heads/master by this push:
new 4464cb0 Change initial version to 0.0.1
new 8af5763 Merge pull request #48 from massakam/change-initial-version
4464cb0 is described below
commit 4464cb0219ae4d67e2220f28dcb06cac5249ab1f
Author: Masahiro Sakamoto
AuthorDate: Thu Aug 22 10:49:41 2019 +0900
Change initial version to 0.0.1
---
README.md | 14 ++
package-lock.json | 2 +-
package.json | 2 +-
3 files changed, 12 insertions(+), 6 deletions(-)
diff --git a/README.md b/README.md
index 8f24c13..d076b21 100644
--- a/README.md
+++ b/README.md
@@ -23,10 +23,6 @@
The Pulsar Node.js client can be used to create Pulsar producers and consumers
in Node.js.
-## Compatibility
-
-This Node.js client is developed and tested using Apache Pulsar 2.3.0
-
## Requirements
Pulsar Node.js client library is based on the C++ client library. Follow the
instructions for
@@ -40,6 +36,16 @@ Pulsar Node.js client library is based on the C++ client
library. Follow the ins
Also, this library works only in Node.js 10.x or later because it uses the
[node-addon-api](https://github.com/nodejs/node-addon-api) module to wrap the
C++ library.
+## Compatibility
+
+Compatibility between each version of the Node.js client and the C++ client is
as follows:
+
+| Node.js client | C++ client |
+|||
+| 0.0.1 | 2.3.0 or later |
+
+If an incompatible version of the C++ client is installed, you may fail to
build or run this library.
+
## How to build
### Install dependent npm modules and build Pulsar client library:
diff --git a/package-lock.json b/package-lock.json
index b885818..4a8725c 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -1,6 +1,6 @@
{
"name": "pulsar-client",
- "version": "2.4.0-SNAPSHOT",
+ "version": "0.0.1-rc.0",
"lockfileVersion": 1,
"requires": true,
"dependencies": {
diff --git a/package.json b/package.json
index c62287d..5798bec 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
{
"name": "pulsar-client",
- "version": "2.4.0-SNAPSHOT",
+ "version": "0.0.1-rc.0",
"description": "Pulsar Node.js client",
"main": "index.js",
"directories": {
[GitHub] [pulsar] nkurihar commented on a change in pull request #5018: Added powered-by page
nkurihar commented on a change in pull request #5018: Added powered-by page
URL: https://github.com/apache/pulsar/pull/5018#discussion_r316939658
##
File path: site2/website/data/users.js
##
@@ -0,0 +1,127 @@
+module.exports = [
+{
+name: 'Narvar',
+url: 'https://corp.narvar.com/',
+logo:
'https://corp.narvar.com/wp-content/themes/narvarinc/dist/images/narvar-logo.svg',
+},
+{
+name: 'Giggso',
+url: 'https://giggso.com/',
+logo:
'https://pbs.twimg.com/profile_banners/4179602009/1470596851/600x200'
+},
+{
+name: 'STICorp',
+url: 'https://www.sticorp.com.br/',
+logo:
'https://www.sticorp.com.br/wp-content/uploads/2015/09/logo-horizontal.png',
+},
+{
+name: 'Verizon Media',
+url: 'https://www.verizonmedia.com/',
+logo:
'https://upload.wikimedia.org/wikipedia/commons/thumb/0/09/Verizon_Media_2019_logo.svg/1200px-Verizon_Media_2019_logo.svg.png'
+},
+{
+name: 'Yahoo! Japan',
Review comment:
Could you modify to Yahoo! **JAPAN** ?
(It's YJ's formal service name)
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] merlimat opened a new pull request #5022: Fixed the cleanup of non-durable cursors when a reader is closed
merlimat opened a new pull request #5022: Fixed the cleanup of non-durable cursors when a reader is closed URL: https://github.com/apache/pulsar/pull/5022 ### Motivation The non-durable cursors associated with readers are not being cleaned up from the managed ledger. This causes these objects to keep hanging around in memory after the reader is gone. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se opened a new issue #5021: Investigate publishing windows python artifacts
aahmed-se opened a new issue #5021: Investigate publishing windows python artifacts URL: https://github.com/apache/pulsar/issues/5021 Github actions has support for windows vm's we should try to use to enable python client generation for windows platforms. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] aahmed-se opened a new pull request #5020: Update supported python osx version docs
aahmed-se opened a new pull request #5020: Update supported python osx version docs URL: https://github.com/apache/pulsar/pull/5020 Minor doc update This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] 01/01: Update supported python osx version docs
This is an automated email from the ASF dual-hosted git repository. aahmed pushed a commit to branch doc1 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 520b336b1d7ac41699e3dd22fdb332ccbe2b943d Author: Ali Ahmed AuthorDate: Thu Aug 22 17:35:09 2019 -0700 Update supported python osx version docs --- site2/docs/client-libraries-python.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/site2/docs/client-libraries-python.md b/site2/docs/client-libraries-python.md index fc5ff28..2e93e96 100644 --- a/site2/docs/client-libraries-python.md +++ b/site2/docs/client-libraries-python.md @@ -22,7 +22,7 @@ Installation via PyPi is available for the following Python versions: Platform | Supported Python versions :|:- -MacOS 10.11 (El Capitan) 10.12 (Sierra) 10.13 (High Sierra) 10.14 (Mojave) | 2.7, 3.7 +MacOS 10.13 (High Sierra), 10.14 (Mojave) | 2.7, 3.7 Linux | 2.7, 3.4, 3.5, 3.6, 3.7 ### Installing from source
[pulsar] branch doc1 created (now 520b336)
This is an automated email from the ASF dual-hosted git repository. aahmed pushed a change to branch doc1 in repository https://gitbox.apache.org/repos/asf/pulsar.git. at 520b336 Update supported python osx version docs This branch includes the following new commits: new 520b336 Update supported python osx version docs The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[GitHub] [pulsar] KannarFr commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message
KannarFr commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message URL: https://github.com/apache/pulsar/issues/5006#issuecomment-524127712 Oh just remember about the version brokers v2.5.0-SNAPSHOT from monday (to handle the fix on schema deletion). Bookies are v2.4.0. I've got a broker exception: ``` Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: 00:30:16.991 [pulsar-io-22-5] WARN org.apache.pulsar.broker.service.ServerCnx - [/192.168.10.15:42368] Got exception BufferUnderflowException : null Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: java.nio.BufferUnderflowException: null Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at java.nio.Buffer.nextGetIndex(Buffer.java:506) ~[?:1.8.0_192] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at java.nio.HeapByteBuffer.getLong(HeapByteBuffer.java:412) ~[?:1.8.0_192] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at org.apache.pulsar.broker.service.schema.BookkeeperSchemaStorage.versionFromBytes(BookkeeperSchemaStorage.java:206) ~[org.apache.pulsar-pulsar-broker-2.5.0-SNAPSHOT.jar:2.5.0-SNAPSHOT] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at org.apache.pulsar.broker.service.schema.SchemaRegistryServiceImpl.versionFromBytes(SchemaRegistryServiceImpl.java:196) ~[org.apache.pulsar-pulsar-broker-2.5.0-SNAPSHOT.jar:2.5.0-SNAPSHOT] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at org.apache.pulsar.broker.service.schema.validator.SchemaRegistryServiceWithSchemaDataValidator.versionFromBytes(SchemaRegistryServiceWithSchemaDataValidator.java:106) ~[org.apache.pulsar-pulsar-broker-2.5.0-SNAPSHOT.jar:2.5.0-SNAPSHOT] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at org.apache.pulsar.broker.service.ServerCnx.handleGetSchema(ServerCnx.java:1334) ~[org.apache.pulsar-pulsar-broker-2.5.0-SNAPSHOT.jar:2.5.0-SNAPSHOT] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at org.apache.pulsar.common.protocol.PulsarDecoder.channelRead(PulsarDecoder.java:306) ~[org.apache.pulsar-pulsar-common-2.5.0-SNAPSHOT.jar:2.5.0-SNAPSHOT] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1
[pulsar] branch github_exp1 updated (0e413a4 -> 40f9817)
This is an automated email from the ASF dual-hosted git repository. aahmed pushed a change to branch github_exp1 in repository https://gitbox.apache.org/repos/asf/pulsar.git. discard 0e413a4 Add Github CI workflow add 40f9817 Add Github CI workflow This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (0e413a4) \ N -- N -- N refs/heads/github_exp1 (40f9817) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .github/workflows/ci.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[pulsar] branch github_exp1 updated (eda3302 -> 0e413a4)
This is an automated email from the ASF dual-hosted git repository. aahmed pushed a change to branch github_exp1 in repository https://gitbox.apache.org/repos/asf/pulsar.git. discard eda3302 Add Github CI workflow add 27a9f62 Need to reinitialize certain components for externally managed runtimes when moving functions (#5007) add ee158d9 Upgrade jackson-databind (#5011) add 958dcfe Modify rest api post schema compatibility strategy (#4950) add 0e413a4 Add Github CI workflow This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (eda3302) \ N -- N -- N refs/heads/github_exp1 (0e413a4) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .github/workflows/ci.yaml | 8 +-- distribution/server/src/assemble/LICENSE.bin.txt | 16 +++--- pom.xml| 5 +- .../apache/pulsar/broker/admin/AdminResource.java | 31 ++ .../pulsar/broker/admin/v2/SchemasResource.java| 66 ++ .../pulsar/broker/admin/AdminApiSchemaTest.java| 42 ++ .../apache/pulsar/io/PulsarFunctionE2ETest.java| 2 +- .../functions/runtime/KubernetesRuntime.java | 24 +--- .../apache/pulsar/functions/runtime/Runtime.java | 4 ++ .../functions/worker/FunctionRuntimeManager.java | 7 +-- .../worker/FunctionRuntimeManagerTest.java | 5 +- pulsar-sql/pom.xml | 2 +- pulsar-sql/presto-distribution/LICENSE | 2 +- pulsar-sql/presto-distribution/pom.xml | 2 +- 14 files changed, 161 insertions(+), 55 deletions(-)
[GitHub] [pulsar] kezhuw edited a comment on issue #5002: Fixes not owned bundles got selected when broker overloading
kezhuw edited a comment on issue #5002: Fixes not owned bundles got selected when broker overloading URL: https://github.com/apache/pulsar/pull/5002#issuecomment-524123596 @sijie I found this issue in reading through `pulsar` not production. What this issue reporting is not-owned-by bundles, eg. bundles that were owned by other brokers, were selected due to broker overloading, not inconsistent between `LocalBrokerData.getBundles` and `LoadData.getBundleData`. I think the testing code is somewhat confusing, may be better to bind ownerless bundles to a not overloaded broker ? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] kezhuw commented on issue #5002: Fixes not owned bundles got selected when broker overloading
kezhuw commented on issue #5002: Fixes not owned bundles got selected when broker overloading URL: https://github.com/apache/pulsar/pull/5002#issuecomment-524123596 @sijie I found this issue in reading through `pulsar` not production. What this issue reporting is not owned-by bundles, eg. bundles that were owned by other brokers, were selected due to broker overloading, not inconsistent between `LocalBrokerData.getBundles` and `LoadData.getBundleData`. I think the testing code is somewhat confusing, may be better to bind ownerless bundles to a not overloaded broker ? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message
sijie commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message URL: https://github.com/apache/pulsar/issues/5006#issuecomment-524122209 @KannarFr the consumer will reading the schema of the version associated with the message it received. so it seems that the consumer stucks at reading the schema info. - what version of broker and client? - any error logs at the broker side? - any error logs at the client side? - can you get a jstack of your test application? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on issue #5016: Add support in cpp client for 1 partitioned topic
sijie commented on issue #5016: Add support in cpp client for 1 partitioned topic URL: https://github.com/apache/pulsar/pull/5016#issuecomment-524120660 retest this please This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on issue #5000: [schema] support uploading key/value schema using Pulsar admin
sijie commented on issue #5000: [schema] support uploading key/value schema using Pulsar admin URL: https://github.com/apache/pulsar/pull/5000#issuecomment-524120458 @congbobo184 can you rebase the pull request to latest master? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie commented on issue #5002: Fixes not owned bundles got selected when broker overloading
sijie commented on issue #5002: Fixes not owned bundles got selected when broker overloading URL: https://github.com/apache/pulsar/pull/5002#issuecomment-524120204 @kezhuw thank you for the fix. although just out of curiosity, at which condition, `bundles` will be inconsistent with `bundleData`? Have you encountered this issue in your production? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] KannarFr edited a comment on issue #5006: AvroSchema in pulsar function producer doesn't output correct message
KannarFr edited a comment on issue #5006: AvroSchema in pulsar function
producer doesn't output correct message
URL: https://github.com/apache/pulsar/issues/5006#issuecomment-524120067
@sijie @jerrypeng
When I run this:
```
public static void main(String[] args) {
try {
PulsarClient client = PulsarClient.builder()
.authentication(new AuthenticationToken(""))
.serviceUrl("")
.build();
AvroSchema schema = AvroSchema.of(ApplicationLog.class);
Producer producer = client.newProducer(schema)
.topic("persistent://public/default/test")
.sendTimeout(10, TimeUnit.SECONDS)
.create();
Consumer consumer = client.newConsumer(schema)
.topic("persistent://public/default/test")
.subscriptionName("test")
.subscribe();
ApplicationLog app = new ApplicationLog();
producer.send(app);
Message msg = consumer.receive();
try {
System.out.println("hello");
System.out.println(msg);
System.out.println(msg.getSchemaVersion());
System.out.println(msg.getData());
System.out.println(msg.getProperties());
System.out.println(msg.getValue());
System.out.println("bye");
consumer.acknowledge(msg);
} catch (Exception e) {
consumer.negativeAcknowledge(msg);
}
} catch (Exception e) {
System.out.println(e.toString());
}
}
```
I got:
```
hello
org.apache.pulsar.client.impl.MessageImpl@1ecee32c
[B@4372b9b6
[B@232a7d73
{}
```
And thats it, it stucks to the getValue(). No exception, just stucked.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] KannarFr commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message
KannarFr commented on issue #5006: AvroSchema in pulsar function producer
doesn't output correct message
URL: https://github.com/apache/pulsar/issues/5006#issuecomment-524120067
@sijie @jerrypeng
When I run this:
```
public static void main(String[] args) {
try {
PulsarClient client = PulsarClient.builder()
.authentication(new AuthenticationToken(""))
.serviceUrl("")
.build();
AvroSchema schema = AvroSchema.of(ApplicationLog.class);
Producer producer = client.newProducer(schema)
.topic("persistent://public/default/test")
.sendTimeout(10, TimeUnit.SECONDS)
.create();
ApplicationLog app = new ApplicationLog();
Consumer consumer = client.newConsumer(schema)
.topic("persistent://public/default/test")
.subscriptionName("test")
.subscribe();
producer.send(app);
Message msg = consumer.receive();
try {
System.out.println("hello");
System.out.println(msg);
System.out.println(msg.getSchemaVersion());
System.out.println(msg.getData());
System.out.println(msg.getProperties());
System.out.println(msg.getValue());
System.out.println("bye");
consumer.acknowledge(msg);
} catch (Exception e) {
consumer.negativeAcknowledge(msg);
}
} catch (Exception e) {
System.out.println(e.toString());
}
}
```
I got:
```
hello
org.apache.pulsar.client.impl.MessageImpl@1ecee32c
[B@4372b9b6
[B@232a7d73
{}
```
And thats it, it stucks to the getValue(). No exception, just stucked.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] sijie commented on issue #4968: [doc] Pulsar Functions: CLI
sijie commented on issue #4968: [doc] Pulsar Functions: CLI URL: https://github.com/apache/pulsar/pull/4968#issuecomment-524119419 run java8 tests This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] [pulsar] sijie closed issue #4821: Pulsar schema api should respect to namespace level compatibility
sijie closed issue #4821: Pulsar schema api should respect to namespace level compatibility URL: https://github.com/apache/pulsar/issues/4821 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] branch master updated (ee158d9 -> 958dcfe)
This is an automated email from the ASF dual-hosted git repository. sijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from ee158d9 Upgrade jackson-databind (#5011) add 958dcfe Modify rest api post schema compatibility strategy (#4950) No new revisions were added by this update. Summary of changes: .../apache/pulsar/broker/admin/AdminResource.java | 31 ++ .../pulsar/broker/admin/v2/SchemasResource.java| 66 ++ .../pulsar/broker/admin/AdminApiSchemaTest.java| 42 ++ 3 files changed, 115 insertions(+), 24 deletions(-)
[GitHub] [pulsar] sijie merged pull request #4950: Modify rest api post schema compatibility strategy
sijie merged pull request #4950: Modify rest api post schema compatibility strategy URL: https://github.com/apache/pulsar/pull/4950 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[pulsar] 01/01: Fix Ccode inspection issues in pulsar borker tests
This is an automated email from the ASF dual-hosted git repository.
aahmed pushed a commit to branch broker_tests_cleanup
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit a4d73379e217e7924ca9c0d177143546b55b440f
Author: Ali Ahmed
AuthorDate: Thu Aug 22 16:30:22 2019 -0700
Fix Ccode inspection issues in pulsar borker tests
---
.gitignore | 1 +
.../org/apache/pulsar/PulsarBrokerStarterTest.java | 8 ++--
.../pulsar/broker/admin/v1/V1_AdminApiTest2.java | 2 +-
.../client/api/MessageDispatchThrottlingTest.java | 2 -
.../pulsar/client/api/MockBrokerServiceHooks.java | 44 +++---
.../api/PartitionedProducerConsumerTest.java | 2 +-
.../client/api/SimpleProducerConsumerTest.java | 6 +--
.../SubscriptionMessageDispatchThrottlingTest.java | 16
.../pulsar/client/api/TlsProducerConsumerTest.java | 6 +--
.../client/api/v1/V1_ProducerConsumerBase.java | 2 +-
.../apache/pulsar/client/impl/RawReaderTest.java | 2 +-
.../pulsar/client/impl/TopicsConsumerImplTest.java | 2 -
.../pulsar/client/impl/ZeroQueueSizeTest.java | 8 +---
.../pulsar/compaction/CompactedTopicTest.java | 5 +--
.../service/web/DiscoveryServiceWebTest.java | 3 +-
.../worker/PulsarFunctionE2ESecurityTest.java | 12 --
.../worker/PulsarFunctionLocalRunTest.java | 16 ++--
.../worker/PulsarFunctionPublishTest.java | 9 -
.../functions/worker/PulsarFunctionStateTest.java | 7 +++-
.../worker/PulsarWorkerAssignmentTest.java | 10 +++--
.../apache/pulsar/io/PulsarFunctionAdminTest.java | 2 +-
.../apache/pulsar/io/PulsarFunctionE2ETest.java| 24 +---
.../apache/pulsar/io/PulsarFunctionTlsTest.java| 11 --
.../pulsar/utils/SimpleTextOutputStreamTest.java | 3 +-
.../apache/pulsar/utils/StatsOutputStreamTest.java | 3 +-
.../proxy/MockAuthenticationProvider.java | 2 +-
.../websocket/proxy/ProxyAuthenticationTest.java | 2 +-
.../websocket/proxy/ProxyPublishConsumeTest.java | 12 +++---
.../proxy/ProxyPublishConsumeTlsTest.java | 2 +-
.../websocket/proxy/SimpleConsumerSocket.java | 4 +-
.../websocket/proxy/SimpleProducerSocket.java | 2 +-
.../proxy/v1/V1_ProxyAuthenticationTest.java | 20 --
32 files changed, 132 insertions(+), 118 deletions(-)
diff --git a/.gitignore b/.gitignore
index fa63e5d..c47cb93 100644
--- a/.gitignore
+++ b/.gitignore
@@ -9,6 +9,7 @@ pulsar-broker/tmp.*
pulsar-broker/src/test/resources/log4j2.yaml
pulsar-functions/worker/test-tenant/
pulsar-broker/src/test/resources/pulsar-functions-api-examples.jar
+pulsar-broker/data/
*.log
*.nar
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/PulsarBrokerStarterTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/PulsarBrokerStarterTest.java
index ba4b212..adc60d8 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/PulsarBrokerStarterTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/PulsarBrokerStarterTest.java
@@ -44,7 +44,7 @@ public class PulsarBrokerStarterTest {
private File createValidBrokerConfigFile() throws FileNotFoundException {
File testConfigFile = new File("tmp." + System.currentTimeMillis() +
".properties");
if (testConfigFile.exists()) {
-testConfigFile.delete();
+assert testConfigFile.delete();
}
PrintWriter printWriter = new PrintWriter(new OutputStreamWriter(new
FileOutputStream(testConfigFile)));
printWriter.println("zookeeperServers=z1.example.com,z2.example.com,z3.example.com");
@@ -134,7 +134,7 @@ public class PulsarBrokerStarterTest {
File testConfigFile = new File("tmp." + System.currentTimeMillis() +
".properties");
if (testConfigFile.exists()) {
-testConfigFile.delete();
+assert testConfigFile.delete();
}
PrintWriter printWriter = new PrintWriter(new OutputStreamWriter(new
FileOutputStream(testConfigFile)));
printWriter.println("brokerDeleteInactiveTopicsEnabled=false");
@@ -168,7 +168,7 @@ public class PulsarBrokerStarterTest {
File testConfigFile = new File("tmp." + System.currentTimeMillis() +
".properties");
if (testConfigFile.exists()) {
-testConfigFile.delete();
+assert testConfigFile.delete();
}
PrintWriter printWriter = new PrintWriter(new OutputStreamWriter(new
FileOutputStream(testConfigFile)));
@@ -217,7 +217,7 @@ public class PulsarBrokerStarterTest {
File testConfigFile = new File("tmp." + System.currentTimeMillis() +
".properties");
if (testConfigFile.exists()) {
-testConfigFile.delete();
+assert testConfigFile.delete();
}
PrintWriter printWriter = new PrintWriter(new OutputStreamWriter(new
FileOutputStream(testConfigFile)));
[pulsar] branch broker_tests_cleanup created (now a4d7337)
This is an automated email from the ASF dual-hosted git repository. aahmed pushed a change to branch broker_tests_cleanup in repository https://gitbox.apache.org/repos/asf/pulsar.git. at a4d7337 Fix Ccode inspection issues in pulsar borker tests This branch includes the following new commits: new a4d7337 Fix Ccode inspection issues in pulsar borker tests The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[GitHub] [pulsar] yittg commented on a change in pull request #5013: [pulsar-client-cpp] cmake isolate auto gen srcs
yittg commented on a change in pull request #5013: [pulsar-client-cpp] cmake
isolate auto gen srcs
URL: https://github.com/apache/pulsar/pull/5013#discussion_r316921202
##
File path: pulsar-client-cpp/CMakeLists.txt
##
@@ -195,9 +195,13 @@ MESSAGE(STATUS "HAS_SNAPPY: ${HAS_SNAPPY}")
set(ADDITIONAL_LIBRARIES $ENV{PULSAR_ADDITIONAL_LIBRARIES})
link_directories( $ENV{PULSAR_ADDITIONAL_LIBRARY_PATH} )
+set(AUTOGEN_DIR ${CMAKE_BINARY_DIR}/generated)
Review comment:
@merlimat `gernerated` added to `.gitignore`, PTAL.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[GitHub] [pulsar] LeisureChou commented on issue #4947: [function]Does the pulsar support connecting to the database in function?
LeisureChou commented on issue #4947: [function]Does the pulsar support
connecting to the database in function?
URL: https://github.com/apache/pulsar/issues/4947#issuecomment-524108229
import lombok.*;
import lombok.experimental.Accessors;
@Data
@Setter
@Getter
@Accessors(chain = true)
@ToString
public class WindowConfig {
public static final String WINDOW_CONFIG_KEY = "__WINDOWCONFIGS__";
/*The number of messages per window*/
private Integer windowLengthCount;
/*The time duration of the window in milliseconds*/
private Long windowLengthDurationMs;
/*The number of messages after which the window slides*/
private Integer slidingIntervalCount;
/*The time duration after which the window slides*/
private Long slidingIntervalDurationMs;
private String lateDataTopic;
private Long maxLagMs;
private Long watermarkEmitIntervalMs;
private String timestampExtractorClassName;
private String actualWindowFunctionClassName;
}
Can I customize my 'timestampExtractorClassName' ? How can I customize it?
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
[pulsar] branch github_exp1 updated (912944f -> eda3302)
This is an automated email from the ASF dual-hosted git repository. aahmed pushed a change to branch github_exp1 in repository https://gitbox.apache.org/repos/asf/pulsar.git. discard 912944f Add Github CI workflow add eda3302 Add Github CI workflow This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (912944f) \ N -- N -- N refs/heads/github_exp1 (eda3302) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .github/workflows/ci.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
