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: Kafk
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/
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/KAFKA-16003
[
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 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 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
Project: Kafka
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
P
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
Issue T
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: Kafka
[
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 option
> --
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
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
Issue Type
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
[
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 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
Issu
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
Issu
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 T
[
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
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 T
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: Bu
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: I
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 Ty
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 Ty
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
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: K
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 Type
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
[
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 offsets
> --
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
Project: Ka
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 Typ
[
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-producer
> -
[
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 could h
[
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 oriented
> --
[
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 an excepti
[
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 tool
> ---
[
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 flush() signature
[
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 not existing
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: Impr
[
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 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 Type
[
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 flush() sign
[
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 tool
[
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 is speci
[
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 a PR for tha
[
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 :(
I asked for
[
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 assigning to me
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
[
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 using th
[
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 you mea
[
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 an ex
[
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 the --cli
[
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 and --value
[
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 and --val
[
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'm going
[
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
[
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
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-
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/
[
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 /tmp is g
[
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 PR ...
Btw I
[
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:23 PM:
-
[
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 ... inside the
[
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 solution. I'd
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/browse/KAFKA-5
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: K
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
Issu
[
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
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
Project
[
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 activity on this sinc
69 matches
Mail list logo
