[jira] [Commented] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17380730#comment-17380730 ] Ewen Cheslack-Postava commented on KAFKA-3539: -- [~moses.nakamura] I spent a bunch of time on

[jira] [Commented] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17343043#comment-17343043 ] Ewen Cheslack-Postava commented on KAFKA-3539: -- [~mjsax] They aren't really duplicates. It's

[jira] [Commented] (KAFKA-6009) Fix formatting of autogenerated docs tables

[ https://issues.apache.org/jira/browse/KAFKA-6009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305855#comment-17305855 ] Ewen Cheslack-Postava commented on KAFKA-6009: -- [~zacky] yes, of course. I've assigned the

[jira] [Assigned] (KAFKA-6009) Fix formatting of autogenerated docs tables

[ https://issues.apache.org/jira/browse/KAFKA-6009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-6009: Assignee: Takeshi Yamasaki > Fix formatting of autogenerated docs tables

[jira] [Commented] (KAFKA-3988) KafkaConfigBackingStore assumes configs will be stored as schemaless maps

[ https://issues.apache.org/jira/browse/KAFKA-3988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294009#comment-17294009 ] Ewen Cheslack-Postava commented on KAFKA-3988: -- [~pachima...@gmail.com] It's marked WONTFIX

[jira] [Commented] (KAFKA-10380) Make dist flatten rocksdbjni

[ https://issues.apache.org/jira/browse/KAFKA-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181366#comment-17181366 ] Ewen Cheslack-Postava commented on KAFKA-10380: --- Probably the best solution would be to

[jira] [Commented] (KAFKA-5896) Kafka Connect task threads never interrupted

[ https://issues.apache.org/jira/browse/KAFKA-5896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177973#comment-17177973 ] Ewen Cheslack-Postava commented on KAFKA-5896: -- [~yazgoo] It looks like this was marked

[jira] [Commented] (KAFKA-9774) Create official Docker image for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-9774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070633#comment-17070633 ] Ewen Cheslack-Postava commented on KAFKA-9774: -- My first reaction to this was that is should

[jira] [Commented] (KAFKA-9468) config.storage.topic partition count issue is hard to debug

[ https://issues.apache.org/jira/browse/KAFKA-9468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022513#comment-17022513 ] Ewen Cheslack-Postava commented on KAFKA-9468: -- [~rhauch] Allowing things to run in that

[jira] [Closed] (KAFKA-5635) KIP-181 Kafka-Connect integrate with kafka ReST Proxy

[ https://issues.apache.org/jira/browse/KAFKA-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava closed KAFKA-5635. > KIP-181 Kafka-Connect integrate with kafka ReST Proxy >

[jira] [Commented] (KAFKA-8586) Source task producers silently fail to send records

[ https://issues.apache.org/jira/browse/KAFKA-8586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16870869#comment-16870869 ] Ewen Cheslack-Postava commented on KAFKA-8586: -- `recordSent` call could probably be moved

[jira] [Closed] (KAFKA-4048) Connect does not support RetriableException consistently for sinks

[ https://issues.apache.org/jira/browse/KAFKA-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava closed KAFKA-4048. > Connect does not support RetriableException consistently for sinks >

[jira] [Commented] (KAFKA-8423) Update ducktape to not use deprecated APIs

[ https://issues.apache.org/jira/browse/KAFKA-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849908#comment-16849908 ] Ewen Cheslack-Postava commented on KAFKA-8423: -- [~htewari] The warning is actually coming

[jira] [Commented] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794652#comment-16794652 ] Ewen Cheslack-Postava commented on KAFKA-2480: -- [~olkuznsmith] I see, you probably got

[jira] [Resolved] (KAFKA-7813) JmxTool throws NPE when --object-name is omitted

[ https://issues.apache.org/jira/browse/KAFKA-7813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7813. -- Resolution: Fixed Fix Version/s: 2.3.0 Issue resolved by pull request

[jira] [Assigned] (KAFKA-7197) Release a milestone build for Scala 2.13.0 M3

[ https://issues.apache.org/jira/browse/KAFKA-7197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-7197: Assignee: Dejan Stojadinović > Release a milestone build for Scala 2.13.0

[jira] [Commented] (KAFKA-2480) Handle non-CopycatExceptions from SinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794612#comment-16794612 ] Ewen Cheslack-Postava commented on KAFKA-2480: -- [~olkuznsmith] This doesn't seem to have

[jira] [Updated] (KAFKA-7834) Extend collected logs in system test services to include heap dumps

[ https://issues.apache.org/jira/browse/KAFKA-7834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-7834: - Fix Version/s: 2.1.2 > Extend collected logs in system test services to include

[jira] [Resolved] (KAFKA-7834) Extend collected logs in system test services to include heap dumps

[ https://issues.apache.org/jira/browse/KAFKA-7834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7834. -- Resolution: Fixed Fix Version/s: (was: 1.1.2)

[jira] [Updated] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5117: - Fix Version/s: 2.0.2 2.1.1 2.2.0 > Kafka

[jira] [Resolved] (KAFKA-7461) Connect Values converter should have coverage of logical types

[ https://issues.apache.org/jira/browse/KAFKA-7461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7461. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request

[jira] [Resolved] (KAFKA-7503) Integration Test Framework for Connect

[ https://issues.apache.org/jira/browse/KAFKA-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7503. -- Resolution: Fixed Fix Version/s: 2.0.2 2.1.1

[jira] [Resolved] (KAFKA-7551) Refactor to create both producer & consumer in Worker

[ https://issues.apache.org/jira/browse/KAFKA-7551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7551. -- Resolution: Fixed Merged [https://github.com/apache/kafka/pull/5842,] my bad

[jira] [Resolved] (KAFKA-7620) ConfigProvider is broken for KafkaConnect when TTL is not null

[ https://issues.apache.org/jira/browse/KAFKA-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7620. -- Resolution: Fixed Fix Version/s: 2.0.2 2.1.1

[jira] [Resolved] (KAFKA-7560) PushHttpMetricsReporter should not convert metric value to double

[ https://issues.apache.org/jira/browse/KAFKA-7560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7560. -- Resolution: Fixed Fix Version/s: 2.1.0 2.2.0 Issue

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663144#comment-16663144 ] Ewen Cheslack-Postava commented on KAFKA-7481: -- [~lindong] I think anything here ends up

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662460#comment-16662460 ] Ewen Cheslack-Postava commented on KAFKA-7481: -- [~lindong] we might just want to update the

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16659935#comment-16659935 ] Ewen Cheslack-Postava commented on KAFKA-7481: -- [~ijuma] As it stands today, is the only use

[jira] [Commented] (KAFKA-7481) Consider options for safer upgrade of offset commit value schema

[ https://issues.apache.org/jira/browse/KAFKA-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16658580#comment-16658580 ] Ewen Cheslack-Postava commented on KAFKA-7481: -- [~ijuma] Arguably your suggestion isn't

[jira] [Resolved] (KAFKA-6490) JSON SerializationException Stops Connect

[ https://issues.apache.org/jira/browse/KAFKA-6490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6490. -- Resolution: Fixed Fix Version/s: 2.0.0 Closing as this is effectively

[jira] [Commented] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error

[ https://issues.apache.org/jira/browse/KAFKA-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16655830#comment-16655830 ] Ewen Cheslack-Postava commented on KAFKA-7510: -- [~mjsax] We should be consistent. Do not log

[jira] [Resolved] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5117. -- Resolution: Duplicate Assignee: Ewen Cheslack-Postava Fix

[jira] [Commented] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640116#comment-16640116 ] Ewen Cheslack-Postava commented on KAFKA-5117: -- Going to close this since 

[jira] [Commented] (KAFKA-7461) Connect Values converter should have coverage of logical types

[ https://issues.apache.org/jira/browse/KAFKA-7461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640101#comment-16640101 ] Ewen Cheslack-Postava commented on KAFKA-7461: -- [~ritabrata1808] I didn't look carefully at

[jira] [Resolved] (KAFKA-7476) SchemaProjector is not properly handling Date-based logical types

[ https://issues.apache.org/jira/browse/KAFKA-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7476. -- Resolution: Fixed Fix Version/s: 2.1.0 0.10.2.3

[jira] [Resolved] (KAFKA-7460) Connect Values converter uses incorrect date format string

[ https://issues.apache.org/jira/browse/KAFKA-7460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7460. -- Resolution: Fixed Fix Version/s: 2.1.0 2.0.1

[jira] [Created] (KAFKA-7460) Connect Values converter uses incorrect date format string

Ewen Cheslack-Postava created KAFKA-7460: Summary: Connect Values converter uses incorrect date format string Key: KAFKA-7460 URL: https://issues.apache.org/jira/browse/KAFKA-7460 Project:

[jira] [Resolved] (KAFKA-7434) DeadLetterQueueReporter throws NPE if transform throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7434. -- Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 Issue

[jira] [Commented] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16608631#comment-16608631 ] Ewen Cheslack-Postava commented on KAFKA-6684: -- [~amitsela] fyi, "not ready yet" was just

[jira] [Commented] (KAFKA-4932) Add UUID Serde

[ https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16608605#comment-16608605 ] Ewen Cheslack-Postava commented on KAFKA-4932: -- [~brandon.kirchner] We included a few config

[jira] [Resolved] (KAFKA-4932) Add UUID Serde

[ https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4932. -- Resolution: Fixed Issue resolved by pull request 4438

[jira] [Resolved] (KAFKA-7353) Connect logs 'this' for anonymous inner classes

[ https://issues.apache.org/jira/browse/KAFKA-7353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7353. -- Resolution: Fixed Fix Version/s: 2.1.0 2.0.1

[jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce

[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16595907#comment-16595907 ] Ewen Cheslack-Postava commented on KAFKA-2260: -- I think it is worth pointing out that this

[jira] [Resolved] (KAFKA-7242) Externalized secrets are revealed in task configuration

[ https://issues.apache.org/jira/browse/KAFKA-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7242. -- Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 Issue

[jira] [Resolved] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7225. -- Resolution: Fixed > Kafka Connect ConfigProvider not invoked before validation

[jira] [Updated] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-7225: - Fix Version/s: 2.1.0 2.0.1 > Kafka Connect ConfigProvider not

[jira] [Updated] (KAFKA-5071) ERROR StreamThread:783 StreamThread-128 - stream-thread [StreamThread-128] Failed to commit StreamTask 0_304 state: org.apache.kafka.streams.errors.ProcessorStateExcepti

[ https://issues.apache.org/jira/browse/KAFKA-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5071: - Summary: ERROR StreamThread:783 StreamThread-128 - stream-thread

[jira] [Resolved] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7228. -- Resolution: Fixed > DeadLetterQueue throws a NullPointerException >

[jira] [Commented] (KAFKA-6889) Fix Streams system test to only specify used log files

[ https://issues.apache.org/jira/browse/KAFKA-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16517504#comment-16517504 ] Ewen Cheslack-Postava commented on KAFKA-6889: -- Globs might be nice, but it looks like the

[jira] [Resolved] (KAFKA-7068) ConfigTransformer doesn't handle null values

[ https://issues.apache.org/jira/browse/KAFKA-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7068. -- Resolution: Fixed Fix Version/s: 2.1.0 Issue resolved by pull request

[jira] [Assigned] (KAFKA-7058) ConnectSchema#equals() broken for array-typed default values

[ https://issues.apache.org/jira/browse/KAFKA-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-7058: Resolution: Fixed Assignee: Ewen Cheslack-Postava

[jira] [Resolved] (KAFKA-7047) Connect isolation whitelist does not include SimpleHeaderConverter

[ https://issues.apache.org/jira/browse/KAFKA-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7047. -- Resolution: Fixed Reviewer: Ewen Cheslack-Postava Fix

[jira] [Resolved] (KAFKA-7039) DelegatingClassLoader creates plugin instance even if its not Versioned

[ https://issues.apache.org/jira/browse/KAFKA-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7039. -- Resolution: Fixed Fix Version/s: 2.1.0 Issue resolved by pull request

[jira] [Resolved] (KAFKA-7056) Connect's new numeric converters should be in a different package

[ https://issues.apache.org/jira/browse/KAFKA-7056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7056. -- Resolution: Fixed Fix Version/s: 2.1.0 Issue resolved by pull request

[jira] [Resolved] (KAFKA-7009) Mute logger for reflections.org at the warn level in system tests

[ https://issues.apache.org/jira/browse/KAFKA-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7009. -- Resolution: Fixed Fix Version/s: 2.1.0 0.11.0.3

[jira] [Resolved] (KAFKA-7031) Kafka Connect API module depends on Jersey

[ https://issues.apache.org/jira/browse/KAFKA-7031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7031. -- Resolution: Fixed Fix Version/s: 2.1.0 Issue resolved by pull request

[jira] [Commented] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16510622#comment-16510622 ] Ewen Cheslack-Postava commented on KAFKA-6161: -- [~chia7712] Really up to [~evis] (we prefer

[jira] [Commented] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

[ https://issues.apache.org/jira/browse/KAFKA-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16510619#comment-16510619 ] Ewen Cheslack-Postava commented on KAFKA-6914: -- [~sriramks85] Spring Boot is handy for

[jira] [Updated] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

[ https://issues.apache.org/jira/browse/KAFKA-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6914: - Fix Version/s: (was: 1.1.1) > Kafka Connect - Plugins class should have a

[jira] [Resolved] (KAFKA-7043) Connect isolation whitelist does not include new primitive converters (KIP-305)

[ https://issues.apache.org/jira/browse/KAFKA-7043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7043. -- Resolution: Fixed Fix Version/s: 2.1.0 Issue resolved by pull request

[jira] [Resolved] (KAFKA-7003) Add headers with error context in messages written to the Connect DeadLetterQueue topic

[ https://issues.apache.org/jira/browse/KAFKA-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7003. -- Resolution: Fixed Fix Version/s: 2.1.0 2.0.0 Issue

[jira] [Commented] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504252#comment-16504252 ] Ewen Cheslack-Postava commented on KAFKA-6161: -- lol, thanks for the offer [~mjsax], that was

[jira] [Commented] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504243#comment-16504243 ] Ewen Cheslack-Postava commented on KAFKA-6161: -- I think it is now a compatible change to

[jira] [Updated] (KAFKA-6161) Introduce new serdes interfaces with empty configure() and close()

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6161: - Labels: needs-kip (was: ) > Introduce new serdes interfaces with empty

[jira] [Updated] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel

[ https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3992: - Fix Version/s: (was: 2.1.0) > InstanceAlreadyExistsException Error for

[jira] [Resolved] (KAFKA-6997) Kafka run class doesn't exclude test-sources jar

[ https://issues.apache.org/jira/browse/KAFKA-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6997. -- Resolution: Fixed Issue resolved by pull request 5139

[jira] [Resolved] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters

[ https://issues.apache.org/jira/browse/KAFKA-6981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6981. -- Resolution: Fixed Issue resolved by pull request 5125

[jira] [Commented] (KAFKA-6914) Kafka Connect - Plugins class should have a constructor that can take in parent ClassLoader

[ https://issues.apache.org/jira/browse/KAFKA-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486603#comment-16486603 ] Ewen Cheslack-Postava commented on KAFKA-6914: -- [~sriramks85] Not sure I understand the use

[jira] [Resolved] (KAFKA-5807) Check Connector.config() and Transformation.config() returns a valid ConfigDef

[ https://issues.apache.org/jira/browse/KAFKA-5807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5807. -- Resolution: Fixed Fix Version/s: 2.0.0 Issue resolved by pull request

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6566: - Fix Version/s: 0.10.2.2 > SourceTask#stop() not called after exception raised in

[jira] [Resolved] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6566. -- Resolution: Fixed > SourceTask#stop() not called after exception raised in

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6566: - Reviewer: Ewen Cheslack-Postava > SourceTask#stop() not called after exception

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6566: - Fix Version/s: 1.1.1 1.0.2 0.11.0.3 >

[jira] [Commented] (KAFKA-6891) send.buffer.bytes should be allowed to set -1 in KafkaConnect

[ https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16469767#comment-16469767 ] Ewen Cheslack-Postava commented on KAFKA-6891: -- [~olkuznsmith] Yeah, agreed. The validation

[jira] [Resolved] (KAFKA-5141) WorkerTest.testCleanupTasksOnStop transient failure due to NPE

[ https://issues.apache.org/jira/browse/KAFKA-5141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5141. -- Resolution: Fixed Assignee: Ewen Cheslack-Postava Not sure of the fix,

[jira] [Commented] (KAFKA-4882) Remove internal converter configuration from example property files

[ https://issues.apache.org/jira/browse/KAFKA-4882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458284#comment-16458284 ] Ewen Cheslack-Postava commented on KAFKA-4882: -- KAFKA-5540 is a generalization of this and

[jira] [Commented] (KAFKA-5635) KIP-181 Kafka-Connect integrate with kafka ReST Proxy

[ https://issues.apache.org/jira/browse/KAFKA-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458273#comment-16458273 ] Ewen Cheslack-Postava commented on KAFKA-5635: -- [~dhananjaydp] I'm inclined to close this as

[jira] [Commented] (KAFKA-6684) Support casting values with bytes schema to string

[ https://issues.apache.org/jira/browse/KAFKA-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16458262#comment-16458262 ] Ewen Cheslack-Postava commented on KAFKA-6684: -- The idea here seems quite similar to the

[jira] [Assigned] (KAFKA-6735) Document how to skip findbugs / checkstyle when running unit test

[ https://issues.apache.org/jira/browse/KAFKA-6735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-6735: Assignee: Ewen Cheslack-Postava > Document how to skip findbugs /

[jira] [Commented] (KAFKA-6735) Document how to skip findbugs / checkstyle when running unit test

[ https://issues.apache.org/jira/browse/KAFKA-6735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16431672#comment-16431672 ] Ewen Cheslack-Postava commented on KAFKA-6735: -- Why should we document outs for these? They

[jira] [Assigned] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-6728: Assignee: Randall Hauch > Kafka Connect Header Null Pointer Exception >

[jira] [Resolved] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6728. -- Resolution: Fixed Fix Version/s: 1.1.1 1.2.0 Issue

[jira] [Assigned] (KAFKA-6725) Indicate "isClosing" in the SinkTaskContext

[ https://issues.apache.org/jira/browse/KAFKA-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-6725: Assignee: Matt Farmer > Indicate "isClosing" in the SinkTaskContext >

[jira] [Commented] (KAFKA-6717) TopicPartition Assined twice to a consumer group for 2 consumer instances

[ https://issues.apache.org/jira/browse/KAFKA-6717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16418435#comment-16418435 ] Ewen Cheslack-Postava commented on KAFKA-6717: -- Are both assigned the partition in the same

[jira] [Commented] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407352#comment-16407352 ] Ewen Cheslack-Postava commented on KAFKA-3821: -- So a couple of points -- * That new

[jira] [Created] (KAFKA-6676) System tests do not handle ZK chroot properly with SCRAM

Ewen Cheslack-Postava created KAFKA-6676: Summary: System tests do not handle ZK chroot properly with SCRAM Key: KAFKA-6676 URL: https://issues.apache.org/jira/browse/KAFKA-6676 Project: Kafka

[jira] [Commented] (KAFKA-6651) SchemaBuilder should not allow Arrays or Maps to be created by type()

[ https://issues.apache.org/jira/browse/KAFKA-6651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401270#comment-16401270 ] Ewen Cheslack-Postava commented on KAFKA-6651: -- Could go either way. Based on the comment, I

[jira] [Commented] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

[ https://issues.apache.org/jira/browse/KAFKA-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401255#comment-16401255 ] Ewen Cheslack-Postava commented on KAFKA-6661: -- Oh, also, I marked it as 1.1.1 release, but

[jira] [Commented] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

[ https://issues.apache.org/jira/browse/KAFKA-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401254#comment-16401254 ] Ewen Cheslack-Postava commented on KAFKA-6661: -- [~rhauch] Got this cherry-picked back to

[jira] [Updated] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

[ https://issues.apache.org/jira/browse/KAFKA-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6661: - Fix Version/s: 1.1.1 1.0.2 0.11.0.3

[jira] [Commented] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords

[ https://issues.apache.org/jira/browse/KAFKA-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16393217#comment-16393217 ] Ewen Cheslack-Postava commented on KAFKA-6626: -- It cannot be a regular map, see the comment

[jira] [Commented] (KAFKA-5939) Add a dryrun option to release.py

[ https://issues.apache.org/jira/browse/KAFKA-5939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390528#comment-16390528 ] Ewen Cheslack-Postava commented on KAFKA-5939: -- I think dry run is fine if we're clear about

[jira] [Commented] (KAFKA-6127) Streams should never block infinitely

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389095#comment-16389095 ] Ewen Cheslack-Postava commented on KAFKA-6127: -- Isn't a basic `poll()` also an issue since it

[jira] [Resolved] (KAFKA-5999) Offset Fetch Request

[ https://issues.apache.org/jira/browse/KAFKA-5999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5999. -- Resolution: Invalid Assignee: Ewen Cheslack-Postava Closing as Invalid

[jira] [Commented] (KAFKA-5799) New KafkaSpoutConfig(Scheme)-ByteArrayKeyValueScheme

[ https://issues.apache.org/jira/browse/KAFKA-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16389064#comment-16389064 ] Ewen Cheslack-Postava commented on KAFKA-5799: -- Is there an actual Kafka issue here? It looks

[jira] [Commented] (KAFKA-5626) Producer should be able to negotiate ProduceRequest version with broker

[ https://issues.apache.org/jira/browse/KAFKA-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16387319#comment-16387319 ] Ewen Cheslack-Postava commented on KAFKA-5626: -- [~lindong] Given KIP-97, is this relevant

[jira] [Resolved] (KAFKA-5471) Original Kafka paper link broken

[ https://issues.apache.org/jira/browse/KAFKA-5471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5471. -- Resolution: Fixed Assignee: Ewen Cheslack-Postava Updated the link to

[jira] [Commented] (KAFKA-5306) Official init.d scripts

[ https://issues.apache.org/jira/browse/KAFKA-5306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16387300#comment-16387300 ] Ewen Cheslack-Postava commented on KAFKA-5306: -- I think the challenge here is that these vary

[jira] [Commented] (KAFKA-5199) Run Kafka JUnit build inside Docker

[ https://issues.apache.org/jira/browse/KAFKA-5199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16387294#comment-16387294 ] Ewen Cheslack-Postava commented on KAFKA-5199: -- [~cmccabe] Do we still need this? I spent

[jira] [Updated] (KAFKA-4999) Add convenience overload for seek* methods

[ https://issues.apache.org/jira/browse/KAFKA-4999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4999: - Component/s: consumer > Add convenience overload for seek* methods >

  1   2   3   >