[GitHub] [pulsar-client-go] wolfstudy opened a new issue #15: [Consumer && Message Impl] Thinking about some code design

wolfstudy opened a new issue #15: [Consumer && Message Impl] Thinking about some code design URL: https://github.com/apache/pulsar-client-go/issues/15 hello @merlimat I am implementing the implementation of consumer and message related, there are several code design issues I want to commun

[pulsar] branch master updated: Refactoring Function Component implementation (#4541)

This is an automated email from the ASF dual-hosted git repository. jerrypeng pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/master by this push: new 95df092 Refactoring Function Component imple

[GitHub] [pulsar] jerrypeng merged pull request #4541: Refactoring Function Component implementation

jerrypeng merged pull request #4541: Refactoring Function Component implementation URL: https://github.com/apache/pulsar/pull/4541 This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [pulsar] jerrypeng commented on a change in pull request #4577: fix issue when submitting NAR via file url

jerrypeng commented on a change in pull request #4577: fix issue when submitting NAR via file url URL: https://github.com/apache/pulsar/pull/4577#discussion_r296538962 ## File path: pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java ###

[GitHub] [pulsar] tuteng commented on issue #3597: [Issue 3275][pulsar-io]Support source and sink of flume

tuteng commented on issue #3597: [Issue 3275][pulsar-io]Support source and sink of flume URL: https://github.com/apache/pulsar/pull/3597#issuecomment-504839114 > @tuteng Can you add some documents for the flume IO connector? Ok, I will add it later. -

[GitHub] [pulsar] yjshen opened a new issue #4586: [Consumer] Subscribe and read from a single partition of a PartitionedTopic will get MessageId's partitionIdx as -1

yjshen opened a new issue #4586: [Consumer] Subscribe and read from a single partition of a PartitionedTopic will get MessageId's partitionIdx as -1 URL: https://github.com/apache/pulsar/issues/4586 When we subscribe to a single partition from a partitioned topic, received messages will ha

[GitHub] [pulsar] jerrypeng commented on issue #4579: add RuntimeUtils test

jerrypeng commented on issue #4579: add RuntimeUtils test URL: https://github.com/apache/pulsar/pull/4579#issuecomment-504838003 rerun java8 tests This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [pulsar] sijie commented on issue #4585: [spark streaming] support spark structured streaming

sijie commented on issue #4585: [spark streaming] support spark structured streaming URL: https://github.com/apache/pulsar/issues/4585#issuecomment-504836970 @yjshen has implemented a comprehensive connector for spark, which included schema integration. He will share the details at Pulsar

[GitHub] [pulsar] sxcooler commented on issue #4481: a little change needed of pulsar cli

sxcooler commented on issue #4481: a little change needed of pulsar cli URL: https://github.com/apache/pulsar/issues/4481#issuecomment-504836319 > @sxcooler Which version are you using? I didn't reproduce this bug on master branch. I was using 2.3.2 on Mac. -

[GitHub] [pulsar] congbobo184 commented on issue #4403: File system offload

congbobo184 commented on issue #4403: File system offload URL: https://github.com/apache/pulsar/pull/4403#issuecomment-504809961 run java8 tests This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [pulsar] codelipenghui commented on issue #3597: [Issue 3275][pulsar-io]Support source and sink of flume

codelipenghui commented on issue #3597: [Issue 3275][pulsar-io]Support source and sink of flume URL: https://github.com/apache/pulsar/pull/3597#issuecomment-504802737 @tuteng Can you add some documents for the flume IO connector?

[GitHub] [pulsar] erenavsarogullari commented on a change in pull request #4539: [Pulsar-Client] Add Producer Builder API Numeric Properties Validations

erenavsarogullari commented on a change in pull request #4539: [Pulsar-Client] Add Producer Builder API Numeric Properties Validations URL: https://github.com/apache/pulsar/pull/4539#discussion_r296498927 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/Produ

[GitHub] [pulsar] erenavsarogullari commented on a change in pull request #4539: [Pulsar-Client] Add Producer Builder API Numeric Properties Validations

erenavsarogullari commented on a change in pull request #4539: [Pulsar-Client] Add Producer Builder API Numeric Properties Validations URL: https://github.com/apache/pulsar/pull/4539#discussion_r296498979 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/Produ

[GitHub] [pulsar] erenavsarogullari commented on a change in pull request #4539: [Pulsar-Client] Add Producer Builder API Numeric Properties Validations

erenavsarogullari commented on a change in pull request #4539: [Pulsar-Client] Add Producer Builder API Numeric Properties Validations URL: https://github.com/apache/pulsar/pull/4539#discussion_r296498962 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/Produ

[GitHub] [pulsar] erenavsarogullari commented on a change in pull request #4539: [Pulsar-Client] Add Producer Builder API Numeric Properties Validations

erenavsarogullari commented on a change in pull request #4539: [Pulsar-Client] Add Producer Builder API Numeric Properties Validations URL: https://github.com/apache/pulsar/pull/4539#discussion_r296498962 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/Produ

[GitHub] [pulsar] erenavsarogullari commented on a change in pull request #4539: [Pulsar-Client] Add Producer Builder API Numeric Properties Validations

erenavsarogullari commented on a change in pull request #4539: [Pulsar-Client] Add Producer Builder API Numeric Properties Validations URL: https://github.com/apache/pulsar/pull/4539#discussion_r296498927 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/Produ

[GitHub] [pulsar] liketic opened a new issue #4585: [spark streaming] support spark structured streaming

liketic opened a new issue #4585: [spark streaming] support spark structured streaming URL: https://github.com/apache/pulsar/issues/4585 Spark structured streaming is the latest program mode of spark streaming, see https://spark.apache.org/docs/latest/structured-streaming-programming-gui

[GitHub] [pulsar] liketic opened a new issue #4584: [spark streaming] Support spark direct stream

liketic opened a new issue #4584: [spark streaming] Support spark direct stream URL: https://github.com/apache/pulsar/issues/4584 Currently, we only support receiver stream. See https://spark.apache.org/docs/2.2.0/streaming-kafka-0-8-integration.html#approach-2-direct-approach-no-receivers

[GitHub] [pulsar] liketic opened a new pull request #4583: [Clean up] Remove redundant parameter totalMessages

liketic opened a new pull request #4583: [Clean up] Remove redundant parameter totalMessages URL: https://github.com/apache/pulsar/pull/4583 Remove redundant parameter ```totalMessages``` for publish method. This is an autom

[GitHub] [pulsar] liketic commented on issue #4481: a little change needed of pulsar cli

liketic commented on issue #4481: a little change needed of pulsar cli URL: https://github.com/apache/pulsar/issues/4481#issuecomment-504758024 @sxcooler Which version are you using? I didn't reproduce this bug on master branch. -

[GitHub] [pulsar] yjmyzz opened a new pull request #4582: Update functions-quickstart.md

yjmyzz opened a new pull request #4582: Update functions-quickstart.md URL: https://github.com/apache/pulsar/pull/4582 classname -> className <-- ### Contribution Checklist - Name the pull request in the form "[Issue XYZ][component] Title of the pull request", where *XY