[GitHub] kafka pull request #3636: KAFKA-5684: KStreamPrintProcessor as customized KS...
Github user ppatierno closed the pull request at: https://github.com/apache/kafka/pull/3636 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3537: KAFKA-5599: ConsoleConsumer : --new-consumer optio...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3537 KAFKA-5599: ConsoleConsumer : --new-consumer option as deprecated Marking --new-consumer as deprecated in the help of ConsoleConsumer Printing a warning on using the new consumer but adding the --new-consumer option You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5599 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3537.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3537 commit 6e9ce80e7dc91365fab1f0fa46332d21c8902af5 Author: ppatierno <ppatie...@live.com> Date: 2017-07-17T10:53:17Z Marking --new-consumer as deprecated in the help of ConsoleConsumer Printing a warning on using the new consumer but adding the --new-consumer option --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3514: KAFKA-5561: Rewrite TopicCommand using the new Adm...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3514 KAFKA-5561: Rewrite TopicCommand using the new Admin client (** WIP do not merge **) Start on porting TopicCommand from Scala to Java using Admin Client API as well Please do not merge it's just for evaluation with other contributors and committers as starting point for a migration from Scala to Java for tools. Other considerations here : https://issues.apache.org/jira/browse/KAFKA-5536 You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5561 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3514.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3514 commit a4146eeab9960d183733bc195516839fc2f76601 Author: ppatierno <ppatie...@live.com> Date: 2017-07-10T10:51:53Z Start on porting TopicCommand from Scala to Java using Admin Client API as well --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3524: KAFKA-5588: uselss --new-consumer option
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3524 KAFKA-5588: uselss --new-consumer option Get rid of the --new-consumer option for the ConsoleConsumer You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5588 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3524.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3524 commit f9309497551c7058696466c06755defddad6238c Author: ppatierno <ppatie...@live.com> Date: 2017-07-13T07:53:16Z Get rid of the --new-consumer option for the ConsoleConsumer --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3551: MINOR: added logging feature for ConfigEntry
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3551 MINOR: added logging feature for ConfigEntry Added toString() ovveride to ConfigEntry for logging You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka admin_config_entry Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3551.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3551 commit 4a404c2a116e3907156396b8e75c42bd66c928ba Author: ppatierno <ppatie...@live.com> Date: 2017-07-20T08:46:42Z Added toString() ovveride to ConfigEntry for logging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3555: KAFKA-5619: Make --new-consumer option as deprecat...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3555 KAFKA-5619: Make --new-consumer option as deprecated in all tools Added deprecation and warning message on --new-consumer option usage with ConsumerGroupCommand and ConsumerPerformance tools. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5619 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3555.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3555 commit a64c57fbcfcace75551af145e71a036f44aab8ba Author: Paolo Patierno <ppatie...@live.com> Date: 2017-07-20T13:08:54Z Updated messages for deprecation and warning if the --new-consumer option is used in ConsumerPerformance tool commit 0ffe1ef1640f47def3cc6f3cae92b91542bfa017 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-07-20T13:31:34Z Updated messages for deprecation and warning if the --new-consumer option is used in ConsumerGroupCommand tool --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3578: KAFKA-5643: Using _DUCKTAPE_OPTIONS has no effect ...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3578 KAFKA-5643: Using _DUCKTAPE_OPTIONS has no effect on executing tests Added handling of _DUCKTAPE_OPTIONS (mainly for enabling debugging) You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5643 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3578.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3578 commit 02e958a1ee7cdd5b7e81fcec45fba7326a4ac9fa Author: Paolo Patierno <ppatie...@live.com> Date: 2017-07-26T09:52:52Z Added handling of _DUCKTAPE_OPTIONS (mainly for enabling debugging) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3577: MINOR: Added some tips for running a single test f...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3577 MINOR: Added some tips for running a single test file, test class and/or test method Added some tips for running a single test file, test class and/or test method on the documentation landing page about tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka minor-tests-doc Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3577.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3577 commit 1381dd34098d3313e74010699102780e94ce6181 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-07-26T08:36:15Z Added some tips for running a single test file, test class and/or test method --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3487: MINOR: Fixed misleading reference to HTTPS instead...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3487 MINOR: Fixed misleading reference to HTTPS instead of SSL support in the doc You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka ssl-doc-https Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3487.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3487 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3488: KAFKA-5557: Using a logPrefix inside the StreamPar...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3488 KAFKA-5557: Using a logPrefix inside the StreamPartitionAssignor Added logPrefix for avoiding stream thread name formatting replicated more times You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5557 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3488.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3488 commit 87a7400acc5feda5828a7fa1604df28a4690c7e2 Author: ppatierno <ppatie...@live.com> Date: 2017-07-05T09:18:02Z Added logPrefix for avoiding stream thread name formatting replicated more times --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3453: KAFKA-5532: Making bootstrap.servers property a fi...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3453 KAFKA-5532: Making bootstrap.servers property a first citizen option for the ProducerPerformance Added bootstrap-server as option for specifying Kafka cluster to connect to You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5532 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3453.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3453 commit 5fe16a3d7a7389d70a6e8c7a7e0b60d5e6ae301f Author: ppatierno <ppatie...@live.com> Date: 2017-06-28T14:44:37Z Added bootstrap-server as option for specifying Kafka cluster to connect to --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3611: MINOR: Added a couple of unit tests for KStreamPri...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3611 MINOR: Added a couple of unit tests for KStreamPrint node when values are bytes With current tests, the deserialization inside the KStreamPrint node processor which happens when key and/or values are byte[] isn't tested. This PR fixes that. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka minor-kstream-print-test Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3611.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3611 commit b463270f3177a94ea3708618834b340d3acf7316 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-08-02T15:15:57Z Added a couple of unit tests for KStreamPrint node when values are bytes --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3636: KAFKA-5684: KStreamPrintProcessor as customized KS...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3636 KAFKA-5684: KStreamPrintProcessor as customized KStreamPeekProcessor This PR is intended for having KStreamPrint derived from KStreamPeek and avoiding the "instance of" check on byte[ ] every process call. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5684 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3636.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3636 commit a516a08bf22cdd53feb4ada50c73dc5a08715b74 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-08-07T12:55:16Z Refactored KStreamPrint as derived from KStreamPeek Removed the "instance of" check for byte[] in every KStreamPrint process, it's up to a default mapper now Updated KStreamPrint tests adapting to the new internal structure for KStreamPrint and PrintForeachAction --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3524: KAFKA-5588: uselss --new-consumer option
Github user ppatierno closed the pull request at: https://github.com/apache/kafka/pull/3524 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3279: KAFKA-5412: Using connect-console-sink/source.prop...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3279 KAFKA-5412: Using connect-console-sink/source.properties raises an exception related to "file" property not found You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5412 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3279.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3279 commit dcbe72dc72f2fcd2fafb84772b5fe5d9e80e1f75 Author: ppatierno <ppatie...@live.com> Date: 2017-06-09T09:13:38Z Added default null value for "file" parameter and more descriptive documentation on its usage --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3383: KAFKA-5481: ListOffsetResponse isn't logged in the...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3383 KAFKA-5481: ListOffsetResponse isn't logged in the right way with trace level enabled Added toString() method to ListOffsetResponse for logging You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5481 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3383.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3383 commit 02bacc15a0de54f0dc75b74789a6922b6da4d83b Author: ppatierno <ppatie...@live.com> Date: 2017-06-20T12:35:33Z Added toString() method to ListOffsetResponse for logging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3434: KAFKA-5516: Formatting verifiable producer/consume...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3434 KAFKA-5516: Formatting verifiable producer/consumer output in a similar fashion You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka verifiable-consumer-producer Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3434.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3434 commit 6e6d728dce83ea689061a196e1b6811b447d4db7 Author: ppatierno <ppatie...@live.com> Date: 2017-06-26T12:07:08Z Modified JSON order attributes in a more readable fashion commit 9235aadfccf446415ffbfd5d90c8d4faeddecc08 Author: ppatierno <ppatie...@live.com> Date: 2017-06-26T12:56:07Z Fixed documentation about old request.required.acks producer parameter Modified JSON order attributes in a more readable fashion Refactoring on verifiable producer to be like the verifiable consumer --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3419: MINOR: Fixed way how logging methods are used for ...
GitHub user ppatierno opened a pull request:
https://github.com/apache/kafka/pull/3419
MINOR: Fixed way how logging methods are used for having a consistent one
In the stream library there are few cases where we don't leverage on
logging methods features (i.e. using {} placeholder instead of string
concatenation or passing the exception variable)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ppatierno/kafka streams-consistent-logging
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/3419.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3419
commit 1f7a5f79186bfff32de6055494b99dbbe82964d5
Author: ppatierno <ppatie...@live.com>
Date: 2017-06-23T10:06:26Z
Fixed way how logging methods are used for having a consistent one
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] kafka pull request #3256: MINOR: Updated .gitignore for excluding out direct...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3256 MINOR: Updated .gitignore for excluding out directory While building the project using IntelliJ IDEA, the "out" directory is generated but not excluded for commit by the .gitignore. Someone could accidentally commit it. This PR add the "out" directory into the .gitignore. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka trunk Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3256.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3256 commit 52ecadd6ede849903cd705f5b5e2b470a8e138bb Author: ppatierno <ppatie...@live.com> Date: 2017-06-07T12:09:53Z Updated .gitignore for excluding out dir --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3268: KAFKA-5410: Fix taskClass() method name in Connect...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3268 KAFKA-5410: Fix taskClass() method name in Connector and flush() signature in SinkTask You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka connect-doc Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3268.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3268 commit 52ecadd6ede849903cd705f5b5e2b470a8e138bb Author: ppatierno <ppatie...@live.com> Date: 2017-06-07T12:09:53Z Updated .gitignore for excluding out dir commit 4b32e4109f67a3b586c3d018277c502fbfad21a2 Author: ppatierno <ppatie...@live.com> Date: 2017-06-08T10:34:52Z Merge remote-tracking branch 'upstream/trunk' into trunk commit 812439d03974ef1794601b85aec5b6c1d54b1e54 Author: ppatierno <ppatie...@live.com> Date: 2017-06-08T10:45:21Z Fixed method name for taskClass() in Connector class Fixed method signature for flush() in SinkTask class --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3268: KAFKA-5410: Fix taskClass() method name in Connect...
Github user ppatierno closed the pull request at: https://github.com/apache/kafka/pull/3268 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3256: MINOR: Updated .gitignore for excluding out direct...
Github user ppatierno closed the pull request at: https://github.com/apache/kafka/pull/3256 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3269: KAFKA-5410: Fix taskClass() method name in Connect...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3269 KAFKA-5410: Fix taskClass() method name in Connector and flush() signature in SinkTask You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka connect-doc Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3269.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3269 commit 1cd05d9154bf64c84651bb0aadb380dafb749bfe Author: ppatierno <ppatie...@live.com> Date: 2017-06-08T11:50:45Z Fixed method name for taskClass() in Connector class Fixed method signature for flush() in SinkTask class --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3301: MINOR: Avoiding attempt to connect to Zookeeper on...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3301 MINOR: Avoiding attempt to connect to Zookeeper on closing consumer for deleting random group.id with the new one With the new consumer the "/consumers" path on Zookeeper isn't filled by consumer info. On closing the new consumer, there is some code that is useless to execute for trying to connect to Zookeeper (but the URL is null). You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka old-consumer-delete-groupid Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3301.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3301 commit c8570fe2e8ef5da8065f0e6129ba19808991c63f Author: ppatierno <ppatie...@live.com> Date: 2017-06-12T09:04:16Z Avoiding attempt to connect to Zookeeper on closing consumer for deleting random group.id with the new one --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3338: KAFKA-5446: Annoying braces showed on log.error us...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3338 KAFKA-5446: Annoying braces showed on log.error using streams Fixed log.error usage with annoying braces You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka log-error Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3338.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3338 commit dcf8308e04663295f9310632dcfc226ea58cd947 Author: ppatierno <ppatie...@live.com> Date: 2017-06-14T13:35:11Z Fixed LOG.error usage with annoying braces --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3335: KAFKA-5434: Console consumer hangs if not existing...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3335 KAFKA-5434: Console consumer hangs if not existing partition is specified Added checking partition exists before assign request You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5434 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3335.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3335 commit 44bbb65994a957866ffc9b7574a4e40870c4f69f Author: ppatierno <ppatie...@live.com> Date: 2017-06-14T08:22:53Z Added checking partition exists before assign request --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3352: KAFKA-5454: Add a new Kafka Streams example IoT or...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3352 KAFKA-5454: Add a new Kafka Streams example IoT oriented Added a Kafka Streams example (IoT oriented) using "tumbling" window You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka stream-temperature-example Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3352.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3352 commit 536fbbfc070053e5bbb07ecfa8b49f7c184497c1 Author: ppatierno <ppatie...@live.com> Date: 2017-06-15T14:56:39Z Added a Kafka Streams example (IoT oriented) using "tumbling" window --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3368: KAFKA-5469: Created state changelog topics not log...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3368 KAFKA-5469: Created state changelog topics not logged correctly Fixed debug logging for the created state changelog topics Added toString() for InternalTopicMetadata and InternalTopicConfig for above debug logging You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5469 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3368.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3368 commit 33d1ce3abdd99c98a8d878d266849347d1f20807 Author: ppatierno <ppatie...@live.com> Date: 2017-06-19T10:56:35Z Fixed debug loggin for the created state changelog topics Added toString() for InternalTopicMetadata and InternalTopicConfig for above debug logging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3302: KAFKA-5409: Providing a custom client-id to the Co...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3302 KAFKA-5409: Providing a custom client-id to the ConsoleProducer tool You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5409 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3302.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3302 commit 591cceaa0fccd76086e4a6a2c232a5e1da85c183 Author: ppatierno <ppatie...@live.com> Date: 2017-06-12T10:48:22Z Fixed the possibility to specify the client.id without being overwritten with a fixed one --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3443: KAFKA-5525: Streams reset tool should have same co...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3443 KAFKA-5525: Streams reset tool should have same console output with or without dry-run Fixed console output to be consistent with/without dry-run option You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5525 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3443.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3443 commit 0cc0161d2907ebc802364b5ff7eb7b99fed7afbc Author: ppatierno <ppatie...@live.com> Date: 2017-06-27T12:52:57Z Fixed console output to be consistent with/without dry-run option --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #3887: KAFKA-5919: Delete records command "version" param...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3887 KAFKA-5919: Delete records command "version" parameter ignored Removed ignored "version" field in JSON file for deleting records You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5919 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3887.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3887 commit ea9bd5e66ae746f1708ea961a049e6656d7eb72c Author: Paolo Patierno <ppatie...@live.com> Date: 2017-09-18T09:49:08Z Removed ignored "version" field in JSON file for deleting records ---
[GitHub] kafka pull request #3885: MINOR: Added ">" prompt in examples where kafka-co...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3885 MINOR: Added ">" prompt in examples where kafka-console-producer is used You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka minor-quickstart-producer Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3885.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3885 commit f96b7a298fee5132235cb72031ff51b9340113bb Author: Paolo Patierno <ppatie...@live.com> Date: 2017-09-18T07:52:48Z Added ">" prompt in examples using kafka-console-producer ---
[GitHub] kafka pull request #4119: MINOR: added -1 value description as "high waterma...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/4119 MINOR: added -1 value description as "high watermark" in the protocol delete records request You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka minor-delrecords-prot Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/4119.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #4119 commit 79fa60f4d5f3f95b94c3bbd86621478763922f1d Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-23T13:57:50Z Added "high watermark" meaning with -1 value for the partition offset during delete records ---
[GitHub] kafka pull request #3885: MINOR: Added ">" prompt in examples where kafka-co...
Github user ppatierno closed the pull request at: https://github.com/apache/kafka/pull/3885 ---
[GitHub] kafka pull request #4132: KAFKA-5925: Adding records deletion operation to t...
GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/4132 KAFKA-5925: Adding records deletion operation to the new Admin Client API This is the PR related to the [KIP-204](https://cwiki.apache.org/confluence/display/KAFKA/KIP-204+%3A+Adding+records+deletion+operation+to+the+new+Admin+Client+API) in order to add the `deleteRecords` operation to the new Admin Client (it's already available in the "legacy" one). Other than that, unit test and integration tests are added as well (such integration tests come from the "legacy" integration tests in order to test the new addition in the same way as the "legacy" one). You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-5925 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/4132.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #4132 commit a2f25eb7337ddea8d421b9e7cc8b3b9adf0349c6 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-09-28T16:33:56Z Started to add skeleton about delete records operation on Admin Client commit 1781192e062f50e720bf44f4c2265ea4ea45577e Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-03T13:54:41Z Added first skeleton for deleteRecords method in the Admin Client commit 4bd2c2112dc310bacb963e4f28bb14472c009a15 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-04T08:41:37Z Completed the DeleteRecordsResult Added handle response logic for the deleteRecords operation commit d4ad3fd6a5e4d9f89ffb320de6de5701f6127d44 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-04T10:09:04Z Fixed wrong checking on no error condition commit e45292004f98c35c93e4d0c4ca6b890e5285044f Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-04T10:54:20Z Added a unit test on Admin Client delete records operation commit 016fb425ad3b27e2d2b22c87539a1fff34842753 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-05T07:40:53Z Updated inheritance of AdminClientIntegrationTest from IntegrationTestHarness for consumer/producer support (delete records tests to add) commit af8162ab3f57b2f60c08c47f1d644bba62d93552 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-20T09:22:48Z Added DeleteRecords class for wrapping long offset commit 1e716f3c57382f8a8f66e81974d7d597dc076f8e Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-20T09:32:50Z Updated AdminClient interface and implementation with new DeleteRecords class commit 7c83dbce7b8b23d0ba51ec99f51180442f5e7e80 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-23T07:53:13Z Renamed DeleteRecords to DeleteRecordsTarget commit fbbccea767afa302e821652fe2b0c07e8e91a395 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-23T15:51:02Z Modified getting metadata strategy using a nested Call approach (metadata then delete records request) Added integration tests as "legacy" admin client tests Added a unit test commit 9e1051620f2f34cbb2a1dfa03c209ab49de9ebd8 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-23T16:18:07Z Minor fix on creating Map instances commit db60a16bc6e21d12318ba52f64cbc7effb32f469 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-24T09:03:54Z Renamed DeleteRecordsTarget to RecordsToDelete with related methods Fixed not working unit test for records deletion commit 749b4076261f24aac582ed8f059c41a7c25cc5b2 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-25T09:00:04Z Minor fixes on unit and integration tests commit 520441183c202f24ff86b375189e25f51142bb32 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-25T09:13:32Z Fixed some style errors after checking commit 599e604d5bb774e5bd90b354a16cf31883b10ae5 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-25T10:13:27Z Fixed conflict with trunk commit ab718b0e6bd5c1afe82803a11ca4bc2e0979e345 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-25T10:19:31Z Merge branch 'trunk' into kafka-5925 commit 80895bf4adfba517c376a0685efe8ec5de7f17c6 Author: Paolo Patierno <ppatie...@live.com> Date: 2017-10-25T10:35:42Z Fixed conflict on generateConfigs method ---
