Re: KAFKA-5723: Refactor BrokerApiVersionsCommand to use the new AdminClient

#x27;s not good for us because we can't go forward with development. Let's see what they say, maybe something like that already happened in the past ... Paolo Patierno Senior Software Engineer (IoT) @ Red Hat Microsoft MVP on Windows Embedded & IoT Microsoft Azure Advisor T

Re: KAFKA-5723: Refactor BrokerApiVersionsCommand to use the new AdminClient

Hi Ismael, first of all thanks for your reply. So as far as I understood having a branch in the Kafka repo could be better for you as committer to validate small PRs from us and not a big one at the end, right ? Paolo Patierno Senior Software Engineer (IoT) @ Red Hat Microsoft MVP on Windows

Re: KAFKA-5723: Refactor BrokerApiVersionsCommand to use the new AdminClient

IRAs related to different tools making their PRs Does this plan make sense ? Paolo Patierno Senior Software Engineer (IoT) @ Red Hat Microsoft MVP on Windows Embedded & IoT Microsoft Azure Advisor Twitter : @ppatierno<http://twitter.com/ppatierno> Linkedin : paolopatierno<http://it.l

Re: [DISCUSS] KIP-195: AdminClient.increasePartitions

My 2 cents about naming ... PartitionCount or NumPartitions sound better to me providing an "absolute" value (as today the kafka-topics script work) for an idempotent operation while the NumPartitionsIncrease name sounds to me like the "increment" value. Paolo Pati

Admin Client : no way to create topic with default partitions and replication factor

set default values in this case. What do you think about that ? Thanks. Paolo Patierno Senior Software Engineer (IoT) @ Red Hat Microsoft MVP on Windows Embedded & IoT Microsoft Azure Advisor Twitter : @ppatierno<http://twitter.com/ppatierno> Linkedin : paolopatierno<http://it.linkedin.com/in/paolopatierno> Blog : DevExperience<http://paolopatierno.wordpress.com/>

[DISCUSS] KIP-204 : adding records deletion operation to the new Admin Client API

A+adding+records+deletion+operation+to+the+new+Admin+Client+API Thanks, Paolo Patierno Senior Software Engineer (IoT) @ Red Hat Microsoft MVP on Azure & IoT Microsoft Azure Advisor Twitter : @ppatierno<http://twitter.com/ppatierno> Linkedin : paolopatierno<http://it.linkedin.com/in/pa

Re: [VOTE] 3.7.0 RC2

ighly-experimental > >>> > > > > > single laptop run! > >>> > > > > > > >>> > > > > > > >>> > > > > > Cheers, > >>> > > > > > > >>> > > > > > Chris >

Re: [VOTE] 3.7.0 RC4

+1 (non-binding). I used the staged binaries with Scala 2.13 and mostly focused on the ZooKeeper to KRaft migration with multiple tests. Everything works fine. Thanks Paolo On Mon, 12 Feb 2024, 22:06 Jakub Scholz, wrote: > +1 (non-binding). I used the staged binaries with Scala 2.13 and the sta

Re: KRaft Observer Nodes

Hi Sanaa, in KRaft mode there is the role of "observer" which is typically taken by brokers as part of the data plane. The broker/observer can discover which node is the leader/active controller and fetches the metadata from it (as the "followers" in the KRaft quorum), but cannot vote and cannot be

Re: KRaft Observer Nodes

indicate that we want a broker to be an observer? > > On Sun, Mar 24, 2024 at 3:01 PM Paolo Patierno > wrote: > > > Hi Sanaa, > > in KRaft mode there is the role of "observer" which is typically taken by > > brokers as part of the data plane. The broker/obs

Re: [ANNOUNCE] New committer: Tom Bentley

Congratulations Tom! Get Outlook for Android From: Guozhang Wang Sent: Monday, March 15, 2021 8:02:44 PM To: dev Subject: Re: [ANNOUNCE] New committer: Tom Bentley Congratulations Tom! Guozhang On Mon, Mar 15, 2021 at 11:25 AM Bill Beje

Starting contribution on Apache Kafka project

Hi Kafka devs, I'd like to start contributing on Kafka and as I read here (http://kafka.apache.org/contributing.html) I'm contacting you to be added to the contributor list so that I could pick up easy JIRAs for getting familiar with it. Is that possible ? Thanks ! Paolo. Paol

[jira] [Reopened] (KAFKA-5588) ConsoleConsumer : uselss --new-consumer option

[ https://issues.apache.org/jira/browse/KAFKA-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno reopened KAFKA-5588: --- > ConsoleConsumer : uselss --new-consumer opt

[jira] [Commented] (KAFKA-5412) Using connect-console-sink/source.properties raises an exception related to "file" property not found

[ https://issues.apache.org/jira/browse/KAFKA-5412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046325#comment-16046325 ] Paolo Patierno commented on KAFKA-5412: --- Sorry [~rhauch], on what version do

[jira] [Commented] (KAFKA-5426) One second delay in kafka-console-producer

[ https://issues.apache.org/jira/browse/KAFKA-5426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046495#comment-16046495 ] Paolo Patierno commented on KAFKA-5426: --- Hi, the linger.ms parameter is set u

[jira] [Created] (KAFKA-5434) Console consumer hangs if not existing partition is specified

Paolo Patierno created KAFKA-5434: - Summary: Console consumer hangs if not existing partition is specified Key: KAFKA-5434 URL: https://issues.apache.org/jira/browse/KAFKA-5434 Project: Kafka

[jira] [Commented] (KAFKA-5434) Console consumer hangs if not existing partition is specified

[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047462#comment-16047462 ] Paolo Patierno commented on KAFKA-5434: --- Hi [~vahid] is it possible assignin

[jira] [Commented] (KAFKA-5434) Console consumer hangs if not existing partition is specified

[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16048035#comment-16048035 ] Paolo Patierno commented on KAFKA-5434: --- [~vahid] I can't do that now :

[jira] [Commented] (KAFKA-5434) Console consumer hangs if not existing partition is specified

[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16048054#comment-16048054 ] Paolo Patierno commented on KAFKA-5434: --- Thank you very much. I'll push

[jira] [Updated] (KAFKA-5434) Console consumer hangs if not existing partition is specified

[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5434: -- Status: Patch Available (was: Open) > Console consumer hangs if not existing partition

[jira] [Updated] (KAFKA-5409) Providing a custom client-id to the ConsoleProducer tool

[ https://issues.apache.org/jira/browse/KAFKA-5409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5409: -- Status: Patch Available (was: Open) > Providing a custom client-id to the ConsoleProducer t

[jira] [Updated] (KAFKA-5410) Fix taskClass() method name in Connector and flush() signature in SinkTask

[ https://issues.apache.org/jira/browse/KAFKA-5410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5410: -- Status: Patch Available (was: Open) > Fix taskClass() method name in Connector and fl

[jira] [Created] (KAFKA-5446) Annoying braces showed on log.error using streams

Paolo Patierno created KAFKA-5446: - Summary: Annoying braces showed on log.error using streams Key: KAFKA-5446 URL: https://issues.apache.org/jira/browse/KAFKA-5446 Project: Kafka Issue

[jira] [Updated] (KAFKA-5446) Annoying braces showed on log.error using streams

[ https://issues.apache.org/jira/browse/KAFKA-5446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5446: -- Status: Patch Available (was: Open) > Annoying braces showed on log.error using stre

[jira] [Created] (KAFKA-5454) Add a new Kafka Streams example IoT oriented

Paolo Patierno created KAFKA-5454: - Summary: Add a new Kafka Streams example IoT oriented Key: KAFKA-5454 URL: https://issues.apache.org/jira/browse/KAFKA-5454 Project: Kafka Issue Type

[jira] [Assigned] (KAFKA-5434) Console consumer hangs if not existing partition is specified

[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno reassigned KAFKA-5434: - Assignee: Paolo Patierno (was: Vahid Hashemian) > Console consumer hangs if

[jira] [Assigned] (KAFKA-5409) Providing a custom client-id to the ConsoleProducer tool

[ https://issues.apache.org/jira/browse/KAFKA-5409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno reassigned KAFKA-5409: - Assignee: Paolo Patierno > Providing a custom client-id to the ConsoleProducer t

[jira] [Assigned] (KAFKA-5410) Fix taskClass() method name in Connector and flush() signature in SinkTask

[ https://issues.apache.org/jira/browse/KAFKA-5410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno reassigned KAFKA-5410: - Assignee: Paolo Patierno > Fix taskClass() method name in Connector and fl

[jira] [Assigned] (KAFKA-5412) Using connect-console-sink/source.properties raises an exception related to "file" property not found

[ https://issues.apache.org/jira/browse/KAFKA-5412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno reassigned KAFKA-5412: - Assignee: Paolo Patierno > Using connect-console-sink/source.properties raises

[jira] [Updated] (KAFKA-5454) Add a new Kafka Streams example IoT oriented

[ https://issues.apache.org/jira/browse/KAFKA-5454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5454: -- Status: Patch Available (was: Open) > Add a new Kafka Streams example IoT orien

[jira] [Commented] (KAFKA-5434) Console consumer hangs if not existing partition is specified

[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050917#comment-16050917 ] Paolo Patierno commented on KAFKA-5434: --- [~vahid] I got your point. Maybe we c

[jira] [Resolved] (KAFKA-5426) One second delay in kafka-console-producer

[ https://issues.apache.org/jira/browse/KAFKA-5426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno resolved KAFKA-5426. --- Resolution: Not A Bug > One second delay in kafka-console-produ

[jira] [Created] (KAFKA-5469) Created state changelog topics not logged correctly

Paolo Patierno created KAFKA-5469: - Summary: Created state changelog topics not logged correctly Key: KAFKA-5469 URL: https://issues.apache.org/jira/browse/KAFKA-5469 Project: Kafka Issue

[jira] [Created] (KAFKA-5481) ListOffsetResponse isn't logged in the right way with trace level enabled

Paolo Patierno created KAFKA-5481: - Summary: ListOffsetResponse isn't logged in the right way with trace level enabled Key: KAFKA-5481 URL: https://issues.apache.org/jira/browse/KAFKA-5481 Pr

[jira] [Resolved] (KAFKA-5506) bin/kafka-consumer-groups.sh failing to query offsets

[ https://issues.apache.org/jira/browse/KAFKA-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno resolved KAFKA-5506. --- Resolution: Not A Problem > bin/kafka-consumer-groups.sh failing to query offs

[jira] [Created] (KAFKA-5516) Formatting verifiable producer/consumer output in a similar fashion

Paolo Patierno created KAFKA-5516: - Summary: Formatting verifiable producer/consumer output in a similar fashion Key: KAFKA-5516 URL: https://issues.apache.org/jira/browse/KAFKA-5516 Project: Kafka

[jira] [Created] (KAFKA-5523) ReplayLogProducer not using the new Kafka consumer

Paolo Patierno created KAFKA-5523: - Summary: ReplayLogProducer not using the new Kafka consumer Key: KAFKA-5523 URL: https://issues.apache.org/jira/browse/KAFKA-5523 Project: Kafka Issue

[jira] [Created] (KAFKA-5525) Streams reset tool should have same console output with or without dry-run

Paolo Patierno created KAFKA-5525: - Summary: Streams reset tool should have same console output with or without dry-run Key: KAFKA-5525 URL: https://issues.apache.org/jira/browse/KAFKA-5525 Project

[jira] [Created] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance

Paolo Patierno created KAFKA-5532: - Summary: Making bootstrap.servers property a first citizen option for the ProducerPerformance Key: KAFKA-5532 URL: https://issues.apache.org/jira/browse/KAFKA-5532

[jira] [Created] (KAFKA-5536) Tools splitted between Java and Scala implementation

Paolo Patierno created KAFKA-5536: - Summary: Tools splitted between Java and Scala implementation Key: KAFKA-5536 URL: https://issues.apache.org/jira/browse/KAFKA-5536 Project: Kafka Issue

[jira] [Created] (KAFKA-5557) Using a logPrefix inside the StreamPartitionAssignor

Paolo Patierno created KAFKA-5557: - Summary: Using a logPrefix inside the StreamPartitionAssignor Key: KAFKA-5557 URL: https://issues.apache.org/jira/browse/KAFKA-5557 Project: Kafka Issue

[jira] [Created] (KAFKA-5561) Rewrite TopicCommand using the new Admin client

Paolo Patierno created KAFKA-5561: - Summary: Rewrite TopicCommand using the new Admin client Key: KAFKA-5561 URL: https://issues.apache.org/jira/browse/KAFKA-5561 Project: Kafka Issue Type

[jira] [Created] (KAFKA-5588) ConsumerConsole : uselss --new-consumer option

Paolo Patierno created KAFKA-5588: - Summary: ConsumerConsole : uselss --new-consumer option Key: KAFKA-5588 URL: https://issues.apache.org/jira/browse/KAFKA-5588 Project: Kafka Issue Type

[jira] [Created] (KAFKA-5599) ConsumerConsole : --new-consumer option as deprecated

Paolo Patierno created KAFKA-5599: - Summary: ConsumerConsole : --new-consumer option as deprecated Key: KAFKA-5599 URL: https://issues.apache.org/jira/browse/KAFKA-5599 Project: Kafka Issue

[jira] [Resolved] (KAFKA-5588) ConsumerConsole : uselss --new-consumer option

[ https://issues.apache.org/jira/browse/KAFKA-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno resolved KAFKA-5588. --- Resolution: Later Before removing the --new-consumer option, the first step is to mark it as

[jira] [Created] (KAFKA-5619) Make --new-consumer option as deprecated in all tools

Paolo Patierno created KAFKA-5619: - Summary: Make --new-consumer option as deprecated in all tools Key: KAFKA-5619 URL: https://issues.apache.org/jira/browse/KAFKA-5619 Project: Kafka Issue

[jira] [Created] (KAFKA-5643) Using _DUCKTAPE_OPTIONS has no effect on executing tests

Paolo Patierno created KAFKA-5643: - Summary: Using _DUCKTAPE_OPTIONS has no effect on executing tests Key: KAFKA-5643 URL: https://issues.apache.org/jira/browse/KAFKA-5643 Project: Kafka

[jira] [Created] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

Paolo Patierno created KAFKA-5684: - Summary: KStreamPrintProcessor as customized KStreamPeekProcessor Key: KAFKA-5684 URL: https://issues.apache.org/jira/browse/KAFKA-5684 Project: Kafka

[jira] [Resolved] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno resolved KAFKA-5684. --- Resolution: Feedback Received > KStreamPrintProcessor as customized KStreamPeekProces

[jira] [Created] (KAFKA-5739) Rewrite KStreamPeekTest at processor level avoiding driver usage

Paolo Patierno created KAFKA-5739: - Summary: Rewrite KStreamPeekTest at processor level avoiding driver usage Key: KAFKA-5739 URL: https://issues.apache.org/jira/browse/KAFKA-5739 Project: Kafka

[jira] [Created] (KAFKA-5919) Delete records command "version" parameter ignored

Paolo Patierno created KAFKA-5919: - Summary: Delete records command "version" parameter ignored Key: KAFKA-5919 URL: https://issues.apache.org/jira/browse/KAFKA-5919 Project: Kafka

[jira] [Created] (KAFKA-5925) Adding records deletion operation to the new Admin Client API

Paolo Patierno created KAFKA-5925: - Summary: Adding records deletion operation to the new Admin Client API Key: KAFKA-5925 URL: https://issues.apache.org/jira/browse/KAFKA-5925 Project: Kafka

[jira] [Created] (KAFKA-15689) KRaftMigrationDriver not logging the skipped event when expected state is wrong

Paolo Patierno created KAFKA-15689: -- Summary: KRaftMigrationDriver not logging the skipped event when expected state is wrong Key: KAFKA-15689 URL: https://issues.apache.org/jira/browse/KAFKA-15689

[jira] [Created] (KAFKA-15754) The kafka-storage tool can generate UUID starting with "-"

Paolo Patierno created KAFKA-15754: -- Summary: The kafka-storage tool can generate UUID starting with "-" Key: KAFKA-15754 URL: https://issues.apache.org/jira/browse/KAFKA-15754 Proj

[jira] [Reopened] (KAFKA-15754) The kafka-storage tool can generate UUID starting with "-"

[ https://issues.apache.org/jira/browse/KAFKA-15754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno reopened KAFKA-15754: > The kafka-storage tool can generate UUID starting w

[jira] [Resolved] (KAFKA-15754) The kafka-storage tool can generate UUID starting with "-"

[ https://issues.apache.org/jira/browse/KAFKA-15754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno resolved KAFKA-15754. Resolution: Not A Problem > The kafka-storage tool can generate UUID starting w

[jira] [Created] (KAFKA-16003) The znode /config/topics is not updated during KRaft migration in "dual-write" mode

Paolo Patierno created KAFKA-16003: -- Summary: The znode /config/topics is not updated during KRaft migration in "dual-write" mode Key: KAFKA-16003 URL: https://issues.apache.org/jira/browse/K

[jira] [Created] (KAFKA-16005) ZooKeeper to KRaft migration rollback missing disabling controller and migration configuration on brokers

Paolo Patierno created KAFKA-16005: -- Summary: ZooKeeper to KRaft migration rollback missing disabling controller and migration configuration on brokers Key: KAFKA-16005 URL: https://issues.apache.org/jira/browse

[jira] [Created] (KAFKA-16101) Kafka cluster unavailable during KRaft migration rollback procedure

Paolo Patierno created KAFKA-16101: -- Summary: Kafka cluster unavailable during KRaft migration rollback procedure Key: KAFKA-16101 URL: https://issues.apache.org/jira/browse/KAFKA-16101 Project

[jira] [Created] (KAFKA-14411) Logging warning when partitions don't exist on assign request

Paolo Patierno created KAFKA-14411: -- Summary: Logging warning when partitions don't exist on assign request Key: KAFKA-14411 URL: https://issues.apache.org/jira/browse/KAFKA-14411 Project:

[jira] [Created] (KAFKA-14883) Broker state should be "observer" in KRaft quorum

Paolo Patierno created KAFKA-14883: -- Summary: Broker state should be "observer" in KRaft quorum Key: KAFKA-14883 URL: https://issues.apache.org/jira/browse/KAFKA-14883 Project: Kafka

[jira] [Commented] (KAFKA-4400) Prefix for sink task consumer groups should be configurable

[ https://issues.apache.org/jira/browse/KAFKA-4400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042325#comment-16042325 ] Paolo Patierno commented on KAFKA-4400: --- [~ewencp] I don't see activit

[jira] [Created] (KAFKA-5408) Using the ConsumerRecord instead of BaseConsumerRecord in the ConsoleConsumer

Paolo Patierno created KAFKA-5408: - Summary: Using the ConsumerRecord instead of BaseConsumerRecord in the ConsoleConsumer Key: KAFKA-5408 URL: https://issues.apache.org/jira/browse/KAFKA-5408

[jira] [Updated] (KAFKA-5408) Using the ConsumerRecord instead of BaseConsumerRecord in the ConsoleConsumer

[ https://issues.apache.org/jira/browse/KAFKA-5408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5408: -- Description: Hi, because the BaseConsumerRecord is marked as deprecated and will be removed in

[jira] [Created] (KAFKA-5409) Providing a custom client-id to the ConsoleProducer tool

Paolo Patierno created KAFKA-5409: - Summary: Providing a custom client-id to the ConsoleProducer tool Key: KAFKA-5409 URL: https://issues.apache.org/jira/browse/KAFKA-5409 Project: Kafka

[jira] [Created] (KAFKA-5410) Fix taskClass() method name in Connector and flush() signature in SinkTask

Paolo Patierno created KAFKA-5410: - Summary: Fix taskClass() method name in Connector and flush() signature in SinkTask Key: KAFKA-5410 URL: https://issues.apache.org/jira/browse/KAFKA-5410 Project

[jira] [Created] (KAFKA-5412) Using connect-console-sink/source.properties raises an exception related to "file" property not found

Paolo Patierno created KAFKA-5412: - Summary: Using connect-console-sink/source.properties raises an exception related to "file" property not found Key: KAFKA-5412 URL: https://issues.apache.org/jira/br

[jira] [Commented] (KAFKA-5412) Using connect-console-sink/source.properties raises an exception related to "file" property not found

[ https://issues.apache.org/jira/browse/KAFKA-5412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16043034#comment-16043034 ] Paolo Patierno commented on KAFKA-5412: --- Yes I agree this is a better solu

[jira] [Commented] (KAFKA-5409) Providing a custom client-id to the ConsoleProducer tool

[ https://issues.apache.org/jira/browse/KAFKA-5409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16043185#comment-16043185 ] Paolo Patierno commented on KAFKA-5409: --- Hi Bharat, you are right but ... in

[jira] [Comment Edited] (KAFKA-5409) Providing a custom client-id to the ConsoleProducer tool

[ https://issues.apache.org/jira/browse/KAFKA-5409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16043185#comment-16043185 ] Paolo Patierno edited comment on KAFKA-5409 at 6/8/17 6:2

[jira] [Commented] (KAFKA-5412) Using connect-console-sink/source.properties raises an exception related to "file" property not found

[ https://issues.apache.org/jira/browse/KAFKA-5412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16043988#comment-16043988 ] Paolo Patierno commented on KAFKA-5412: --- Thanks [~rhauch] ! I'll do the P

[jira] [Commented] (KAFKA-3925) Default log.dir=/tmp/kafka-logs is unsafe

[ https://issues.apache.org/jira/browse/KAFKA-3925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16044002#comment-16044002 ] Paolo Patierno commented on KAFKA-3925: --- In my opinion, putting the log in /tm

[jira] [Created] (KAFKA-5419) Console consumer --key-deserializer and --value-deserializer are always overwritten by ByteArrayDeserializer

Paolo Patierno created KAFKA-5419: - Summary: Console consumer --key-deserializer and --value-deserializer are always overwritten by ByteArrayDeserializer Key: KAFKA-5419 URL: https://issues.apache.org/jira/browse

[jira] [Created] (KAFKA-5420) Console producer --key-serializer and --value-serializer are always overwritten by ByteArraySerializer

Paolo Patierno created KAFKA-5420: - Summary: Console producer --key-serializer and --value-serializer are always overwritten by ByteArraySerializer Key: KAFKA-5420 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Updated] (KAFKA-5420) Console producer --key-serializer and --value-serializer are always overwritten by ByteArraySerializer

[ https://issues.apache.org/jira/browse/KAFKA-5420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5420: -- Description: Hi, the --key-serializer and --value-serializer options passed to the command line

[jira] [Updated] (KAFKA-5419) Console consumer --key-deserializer and --value-deserializer are always overwritten by ByteArrayDeserializer

[ https://issues.apache.org/jira/browse/KAFKA-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5419: -- Description: Hi, the --key-deserializer and --value-deserializer options passed to the command

[jira] [Commented] (KAFKA-5419) Console consumer --key-deserializer and --value-deserializer are always overwritten by ByteArrayDeserializer

[ https://issues.apache.org/jira/browse/KAFKA-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16044572#comment-16044572 ] Paolo Patierno commented on KAFKA-5419: --- Yes I think you are right sorry. I

[jira] [Resolved] (KAFKA-5419) Console consumer --key-deserializer and --value-deserializer are always overwritten by ByteArrayDeserializer

[ https://issues.apache.org/jira/browse/KAFKA-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno resolved KAFKA-5419. --- Resolution: Duplicate Duplicate of KAFKA-2526 > Console consumer --key-deserializer

[jira] [Resolved] (KAFKA-5420) Console producer --key-serializer and --value-serializer are always overwritten by ByteArraySerializer

[ https://issues.apache.org/jira/browse/KAFKA-5420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno resolved KAFKA-5420. --- Resolution: Duplicate Duplicate of KAFKA-2526 > Console producer --key-serializer

[jira] [Commented] (KAFKA-5409) Providing a custom client-id to the ConsoleProducer tool

[ https://issues.apache.org/jira/browse/KAFKA-5409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16044592#comment-16044592 ] Paolo Patierno commented on KAFKA-5409: --- I think that we can leave without

[jira] [Updated] (KAFKA-5412) Using connect-console-sink/source.properties raises an exception related to "file" property not found

[ https://issues.apache.org/jira/browse/KAFKA-5412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5412: -- Status: Patch Available (was: Open) > Using connect-console-sink/source.properties raises

<    1   2