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
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
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
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 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 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
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
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
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
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
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
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
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 byt
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
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:
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
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
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
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. Som
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
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
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
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
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 is
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 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
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
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
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
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
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 r
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/pp
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
Github user ppatierno closed the pull request at:
https://github.com/apache/kafka/pull/3885
---
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
35 matches
Mail list logo
